github/containerd
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

Fix 'forward' typos

Browse Source 
Signed-off-by: Xiaoxi He <xxhe@alauda.io>
This commit is contained in:
Xiaoxi He
2018-09-07 13:23:55 +08:00
parent 901b2ea2a7
commit 9f817000cc
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
api/services/events/v1/events.pb.go
View File

@@ -141,7 +141,7 @@ type EventsClient interface {
// Forward sends an event that has already been packaged into an envelope // Forward sends an event that has already been packaged into an envelope
// with a timestamp and namespace. // with a timestamp and namespace.
// //
// This is useful if earlier timestamping is required or when fowarding on // This is useful if earlier timestamping is required or when forwarding on
// behalf of another component, namespace or publisher. // behalf of another component, namespace or publisher.
Forward(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (*google_protobuf2.Empty, error) Forward(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (*google_protobuf2.Empty, error)
// Subscribe to a stream of events, possibly returning only that match any // Subscribe to a stream of events, possibly returning only that match any
@@ -223,7 +223,7 @@ type EventsServer interface {
// Forward sends an event that has already been packaged into an envelope // Forward sends an event that has already been packaged into an envelope
// with a timestamp and namespace. // with a timestamp and namespace.
// //
// This is useful if earlier timestamping is required or when fowarding on // This is useful if earlier timestamping is required or when forwarding on
// behalf of another component, namespace or publisher. // behalf of another component, namespace or publisher.
Forward(context.Context, *ForwardRequest) (*google_protobuf2.Empty, error) Forward(context.Context, *ForwardRequest) (*google_protobuf2.Empty, error)
// Subscribe to a stream of events, possibly returning only that match any // Subscribe to a stream of events, possibly returning only that match any

2
api/services/events/v1/events.proto
View File

@@ -20,7 +20,7 @@ service Events {
// Forward sends an event that has already been packaged into an envelope // Forward sends an event that has already been packaged into an envelope
// with a timestamp and namespace. // with a timestamp and namespace.
// //
// This is useful if earlier timestamping is required or when fowarding on // This is useful if earlier timestamping is required or when forwarding on
// behalf of another component, namespace or publisher. // behalf of another component, namespace or publisher.
rpc Forward(ForwardRequest) returns (google.protobuf.Empty); rpc Forward(ForwardRequest) returns (google.protobuf.Empty);

2
events/exchange/exchange.go
View File

@@ -52,7 +52,7 @@ var _ events.Subscriber = &Exchange{}
// Forward accepts an envelope to be direcly distributed on the exchange. // Forward accepts an envelope to be direcly distributed on the exchange.
// //
// This is useful when an event is forwaded on behalf of another namespace or // This is useful when an event is forwarded on behalf of another namespace or
// when the event is propagated on behalf of another publisher. // when the event is propagated on behalf of another publisher.
func (e *Exchange) Forward(ctx context.Context, envelope *events.Envelope) (err error) { func (e *Exchange) Forward(ctx context.Context, envelope *events.Envelope) (err error) {
if err := validateEnvelope(envelope); err != nil { if err := validateEnvelope(envelope); err != nil {