api

package
v1.0.0-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 15, 2020 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDiscovery = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDiscovery   = fmt.Errorf("proto: integer overflow")
)
View Source 
var DependencyDiscoveryRequestJSONMarshaler = new(jsonpb.Marshaler)

DependencyDiscoveryRequestJSONMarshaler describes the default jsonpb.Marshaler used by all instances of DependencyDiscoveryRequest. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var DependencyDiscoveryRequestJSONUnmarshaler = new(jsonpb.Unmarshaler)

DependencyDiscoveryRequestJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of DependencyDiscoveryRequest. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var DependencyDiscoveryResponseJSONMarshaler = new(jsonpb.Marshaler)

DependencyDiscoveryResponseJSONMarshaler describes the default jsonpb.Marshaler used by all instances of DependencyDiscoveryResponse. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var DependencyDiscoveryResponseJSONUnmarshaler = new(jsonpb.Unmarshaler)

DependencyDiscoveryResponseJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of DependencyDiscoveryResponse. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var SvcConfigDiscoveryRequestJSONMarshaler = new(jsonpb.Marshaler)

SvcConfigDiscoveryRequestJSONMarshaler describes the default jsonpb.Marshaler used by all instances of SvcConfigDiscoveryRequest. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var SvcConfigDiscoveryRequestJSONUnmarshaler = new(jsonpb.Unmarshaler)

SvcConfigDiscoveryRequestJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of SvcConfigDiscoveryRequest. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var SvcConfigDiscoveryResponseJSONMarshaler = new(jsonpb.Marshaler)

SvcConfigDiscoveryResponseJSONMarshaler describes the default jsonpb.Marshaler used by all instances of SvcConfigDiscoveryResponse. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var SvcConfigDiscoveryResponseJSONUnmarshaler = new(jsonpb.Unmarshaler)

SvcConfigDiscoveryResponseJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of SvcConfigDiscoveryResponse. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var SvcEndpointDiscoveryRequestJSONMarshaler = new(jsonpb.Marshaler)

SvcEndpointDiscoveryRequestJSONMarshaler describes the default jsonpb.Marshaler used by all instances of SvcEndpointDiscoveryRequest. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var SvcEndpointDiscoveryRequestJSONUnmarshaler = new(jsonpb.Unmarshaler)

SvcEndpointDiscoveryRequestJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of SvcEndpointDiscoveryRequest. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var SvcEndpointDiscoveryResponseJSONMarshaler = new(jsonpb.Marshaler)

SvcEndpointDiscoveryResponseJSONMarshaler describes the default jsonpb.Marshaler used by all instances of SvcEndpointDiscoveryResponse. This struct is safe to replace or modify but should not be done so concurrently.

View Source 
var SvcEndpointDiscoveryResponseJSONUnmarshaler = new(jsonpb.Unmarshaler)

SvcEndpointDiscoveryResponseJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of SvcEndpointDiscoveryResponse. This struct is safe to replace or modify but should not be done so concurrently.

Functions

func RegisterDiscoveryServiceServer 

func RegisterDiscoveryServiceServer(s *grpc.Server, srv DiscoveryServiceServer)

Types

type DependencyDiscoveryRequest 

type DependencyDiscoveryRequest struct {
	// Meta information of the current instance.
	Instance             *common.Instance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DependencyDiscoveryRequest) Descriptor 

func (*DependencyDiscoveryRequest) Descriptor() ([]byte, []int)

func (*DependencyDiscoveryRequest) Equal 

func (this *DependencyDiscoveryRequest) Equal(that interface{}) bool

func (*DependencyDiscoveryRequest) GetInstance 

func (m *DependencyDiscoveryRequest) GetInstance() *common.Instance

func (*DependencyDiscoveryRequest) GoString 

func (this *DependencyDiscoveryRequest) GoString() string

func (*DependencyDiscoveryRequest) Marshal 

func (m *DependencyDiscoveryRequest) Marshal() (dAtA []byte, err error)

func (*DependencyDiscoveryRequest) MarshalJSON 

func (m *DependencyDiscoveryRequest) MarshalJSON() ([]byte, error)

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*DependencyDiscoveryRequest) MarshalTo 

func (m *DependencyDiscoveryRequest) MarshalTo(dAtA []byte) (int, error)

func (*DependencyDiscoveryRequest) MarshalToSizedBuffer 

func (m *DependencyDiscoveryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DependencyDiscoveryRequest) ProtoMessage 

func (*DependencyDiscoveryRequest) ProtoMessage()

func (*DependencyDiscoveryRequest) Reset 

func (m *DependencyDiscoveryRequest) Reset()

func (*DependencyDiscoveryRequest) Size 

func (m *DependencyDiscoveryRequest) Size() (n int)

func (*DependencyDiscoveryRequest) String 

func (m *DependencyDiscoveryRequest) String() string

func (*DependencyDiscoveryRequest) Unmarshal 

func (m *DependencyDiscoveryRequest) Unmarshal(dAtA []byte) error

func (*DependencyDiscoveryRequest) UnmarshalJSON 

func (m *DependencyDiscoveryRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*DependencyDiscoveryRequest) Validate 

func (m *DependencyDiscoveryRequest) Validate() error

Validate checks the field values on DependencyDiscoveryRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*DependencyDiscoveryRequest) VerboseEqual 

func (this *DependencyDiscoveryRequest) VerboseEqual(that interface{}) error

func (*DependencyDiscoveryRequest) XXX_DiscardUnknown 

func (m *DependencyDiscoveryRequest) XXX_DiscardUnknown()

func (*DependencyDiscoveryRequest) XXX_Marshal 

func (m *DependencyDiscoveryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DependencyDiscoveryRequest) XXX_Merge 

func (m *DependencyDiscoveryRequest) XXX_Merge(src proto.Message)

func (*DependencyDiscoveryRequest) XXX_Size 

func (m *DependencyDiscoveryRequest) XXX_Size() int

func (*DependencyDiscoveryRequest) XXX_Unmarshal 

func (m *DependencyDiscoveryRequest) XXX_Unmarshal(b []byte) error

type DependencyDiscoveryRequestValidationError 

type DependencyDiscoveryRequestValidationError struct {
	// contains filtered or unexported fields
}

DependencyDiscoveryRequestValidationError is the validation error returned by DependencyDiscoveryRequest.Validate if the designated constraints aren't met.

func (DependencyDiscoveryRequestValidationError) Cause 

func (e DependencyDiscoveryRequestValidationError) Cause() error

Cause function returns cause value.

func (DependencyDiscoveryRequestValidationError) Error 

func (e DependencyDiscoveryRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DependencyDiscoveryRequestValidationError) ErrorName 

func (e DependencyDiscoveryRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DependencyDiscoveryRequestValidationError) Field 

func (e DependencyDiscoveryRequestValidationError) Field() string

Field function returns field value.

func (DependencyDiscoveryRequestValidationError) Key 

func (e DependencyDiscoveryRequestValidationError) Key() bool

Key function returns key value.

func (DependencyDiscoveryRequestValidationError) Reason 

func (e DependencyDiscoveryRequestValidationError) Reason() string

Reason function returns reason value.

type DependencyDiscoveryResponse 

type DependencyDiscoveryResponse struct {
	// Added service.
	Added []*service.Service `protobuf:"bytes,1,rep,name=added,proto3" json:"added,omitempty"`
	// Removed service.
	Removed              []*service.Service `protobuf:"bytes,2,rep,name=removed,proto3" json:"removed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*DependencyDiscoveryResponse) Descriptor 

func (*DependencyDiscoveryResponse) Descriptor() ([]byte, []int)

func (*DependencyDiscoveryResponse) Equal 

func (this *DependencyDiscoveryResponse) Equal(that interface{}) bool

func (*DependencyDiscoveryResponse) GetAdded 

func (m *DependencyDiscoveryResponse) GetAdded() []*service.Service

func (*DependencyDiscoveryResponse) GetRemoved 

func (m *DependencyDiscoveryResponse) GetRemoved() []*service.Service

func (*DependencyDiscoveryResponse) GoString 

func (this *DependencyDiscoveryResponse) GoString() string

func (*DependencyDiscoveryResponse) Marshal 

func (m *DependencyDiscoveryResponse) Marshal() (dAtA []byte, err error)

func (*DependencyDiscoveryResponse) MarshalJSON 

func (m *DependencyDiscoveryResponse) MarshalJSON() ([]byte, error)

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*DependencyDiscoveryResponse) MarshalTo 

func (m *DependencyDiscoveryResponse) MarshalTo(dAtA []byte) (int, error)

func (*DependencyDiscoveryResponse) MarshalToSizedBuffer 

func (m *DependencyDiscoveryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DependencyDiscoveryResponse) ProtoMessage 

func (*DependencyDiscoveryResponse) ProtoMessage()

func (*DependencyDiscoveryResponse) Reset 

func (m *DependencyDiscoveryResponse) Reset()

func (*DependencyDiscoveryResponse) Size 

func (m *DependencyDiscoveryResponse) Size() (n int)

func (*DependencyDiscoveryResponse) String 

func (m *DependencyDiscoveryResponse) String() string

func (*DependencyDiscoveryResponse) Unmarshal 

func (m *DependencyDiscoveryResponse) Unmarshal(dAtA []byte) error

func (*DependencyDiscoveryResponse) UnmarshalJSON 

func (m *DependencyDiscoveryResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*DependencyDiscoveryResponse) Validate 

func (m *DependencyDiscoveryResponse) Validate() error

Validate checks the field values on DependencyDiscoveryResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*DependencyDiscoveryResponse) VerboseEqual 

func (this *DependencyDiscoveryResponse) VerboseEqual(that interface{}) error

func (*DependencyDiscoveryResponse) XXX_DiscardUnknown 

func (m *DependencyDiscoveryResponse) XXX_DiscardUnknown()

func (*DependencyDiscoveryResponse) XXX_Marshal 

func (m *DependencyDiscoveryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DependencyDiscoveryResponse) XXX_Merge 

func (m *DependencyDiscoveryResponse) XXX_Merge(src proto.Message)

func (*DependencyDiscoveryResponse) XXX_Size 

func (m *DependencyDiscoveryResponse) XXX_Size() int

func (*DependencyDiscoveryResponse) XXX_Unmarshal 

func (m *DependencyDiscoveryResponse) XXX_Unmarshal(b []byte) error

type DependencyDiscoveryResponseValidationError 

type DependencyDiscoveryResponseValidationError struct {
	// contains filtered or unexported fields
}

DependencyDiscoveryResponseValidationError is the validation error returned by DependencyDiscoveryResponse.Validate if the designated constraints aren't met.

func (DependencyDiscoveryResponseValidationError) Cause 

func (e DependencyDiscoveryResponseValidationError) Cause() error

Cause function returns cause value.

func (DependencyDiscoveryResponseValidationError) Error 

func (e DependencyDiscoveryResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DependencyDiscoveryResponseValidationError) ErrorName 

func (e DependencyDiscoveryResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DependencyDiscoveryResponseValidationError) Field 

func (e DependencyDiscoveryResponseValidationError) Field() string

Field function returns field value.

func (DependencyDiscoveryResponseValidationError) Key 

func (e DependencyDiscoveryResponseValidationError) Key() bool

Key function returns key value.

func (DependencyDiscoveryResponseValidationError) Reason 

func (e DependencyDiscoveryResponseValidationError) Reason() string

Reason function returns reason value.

type DiscoveryServiceClient 

type DiscoveryServiceClient interface {
	StreamDependencies(ctx context.Context, in *DependencyDiscoveryRequest, opts ...grpc.CallOption) (DiscoveryService_StreamDependenciesClient, error)
	StreamSvcConfigs(ctx context.Context, opts ...grpc.CallOption) (DiscoveryService_StreamSvcConfigsClient, error)
	StreamSvcEndpoints(ctx context.Context, opts ...grpc.CallOption) (DiscoveryService_StreamSvcEndpointsClient, error)
}

DiscoveryServiceClient is the client API for DiscoveryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDiscoveryServiceClient 

func NewDiscoveryServiceClient(cc *grpc.ClientConn) DiscoveryServiceClient

type DiscoveryServiceServer 

type DiscoveryServiceServer interface {
	StreamDependencies(*DependencyDiscoveryRequest, DiscoveryService_StreamDependenciesServer) error
	StreamSvcConfigs(DiscoveryService_StreamSvcConfigsServer) error
	StreamSvcEndpoints(DiscoveryService_StreamSvcEndpointsServer) error
}

DiscoveryServiceServer is the server API for DiscoveryService service.

type DiscoveryService_StreamDependenciesClient 

type DiscoveryService_StreamDependenciesClient interface {
	Recv() (*DependencyDiscoveryResponse, error)
	grpc.ClientStream
}

type DiscoveryService_StreamDependenciesServer 

type DiscoveryService_StreamDependenciesServer interface {
	Send(*DependencyDiscoveryResponse) error
	grpc.ServerStream
}

type DiscoveryService_StreamSvcConfigsClient 

type DiscoveryService_StreamSvcConfigsClient interface {
	Send(*SvcConfigDiscoveryRequest) error
	Recv() (*SvcConfigDiscoveryResponse, error)
	grpc.ClientStream
}

type DiscoveryService_StreamSvcConfigsServer 

type DiscoveryService_StreamSvcConfigsServer interface {
	Send(*SvcConfigDiscoveryResponse) error
	Recv() (*SvcConfigDiscoveryRequest, error)
	grpc.ServerStream
}

type DiscoveryService_StreamSvcEndpointsClient 

type DiscoveryService_StreamSvcEndpointsClient interface {
	Send(*SvcEndpointDiscoveryRequest) error
	Recv() (*SvcEndpointDiscoveryResponse, error)
	grpc.ClientStream
}

type DiscoveryService_StreamSvcEndpointsServer 

type DiscoveryService_StreamSvcEndpointsServer interface {
	Send(*SvcEndpointDiscoveryResponse) error
	Recv() (*SvcEndpointDiscoveryRequest, error)
	grpc.ServerStream
}

type SvcConfigDiscoveryRequest 

type SvcConfigDiscoveryRequest struct {
	// All service names that need to subscribe.
	SvcNamesSubscribe []string `protobuf:"bytes,1,rep,name=svc_names_subscribe,json=svcNamesSubscribe,proto3" json:"svc_names_subscribe,omitempty"`
	// All service names that need to unsubscribe.
	SvcNamesUnsubscribe  []string `protobuf:"bytes,2,rep,name=svc_names_unsubscribe,json=svcNamesUnsubscribe,proto3" json:"svc_names_unsubscribe,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SvcConfigDiscoveryRequest) Descriptor 

func (*SvcConfigDiscoveryRequest) Descriptor() ([]byte, []int)

func (*SvcConfigDiscoveryRequest) Equal 

func (this *SvcConfigDiscoveryRequest) Equal(that interface{}) bool

func (*SvcConfigDiscoveryRequest) GetSvcNamesSubscribe 

func (m *SvcConfigDiscoveryRequest) GetSvcNamesSubscribe() []string

func (*SvcConfigDiscoveryRequest) GetSvcNamesUnsubscribe 

func (m *SvcConfigDiscoveryRequest) GetSvcNamesUnsubscribe() []string

func (*SvcConfigDiscoveryRequest) GoString 

func (this *SvcConfigDiscoveryRequest) GoString() string

func (*SvcConfigDiscoveryRequest) Marshal 

func (m *SvcConfigDiscoveryRequest) Marshal() (dAtA []byte, err error)

func (*SvcConfigDiscoveryRequest) MarshalJSON 

func (m *SvcConfigDiscoveryRequest) MarshalJSON() ([]byte, error)

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*SvcConfigDiscoveryRequest) MarshalTo 

func (m *SvcConfigDiscoveryRequest) MarshalTo(dAtA []byte) (int, error)

func (*SvcConfigDiscoveryRequest) MarshalToSizedBuffer 

func (m *SvcConfigDiscoveryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SvcConfigDiscoveryRequest) ProtoMessage 

func (*SvcConfigDiscoveryRequest) ProtoMessage()

func (*SvcConfigDiscoveryRequest) Reset 

func (m *SvcConfigDiscoveryRequest) Reset()

func (*SvcConfigDiscoveryRequest) Size 

func (m *SvcConfigDiscoveryRequest) Size() (n int)

func (*SvcConfigDiscoveryRequest) String 

func (m *SvcConfigDiscoveryRequest) String() string

func (*SvcConfigDiscoveryRequest) Unmarshal 

func (m *SvcConfigDiscoveryRequest) Unmarshal(dAtA []byte) error

func (*SvcConfigDiscoveryRequest) UnmarshalJSON 

func (m *SvcConfigDiscoveryRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*SvcConfigDiscoveryRequest) Validate 

func (m *SvcConfigDiscoveryRequest) Validate() error

Validate checks the field values on SvcConfigDiscoveryRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SvcConfigDiscoveryRequest) VerboseEqual 

func (this *SvcConfigDiscoveryRequest) VerboseEqual(that interface{}) error

func (*SvcConfigDiscoveryRequest) XXX_DiscardUnknown 

func (m *SvcConfigDiscoveryRequest) XXX_DiscardUnknown()

func (*SvcConfigDiscoveryRequest) XXX_Marshal 

func (m *SvcConfigDiscoveryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SvcConfigDiscoveryRequest) XXX_Merge 

func (m *SvcConfigDiscoveryRequest) XXX_Merge(src proto.Message)

func (*SvcConfigDiscoveryRequest) XXX_Size 

func (m *SvcConfigDiscoveryRequest) XXX_Size() int

func (*SvcConfigDiscoveryRequest) XXX_Unmarshal 

func (m *SvcConfigDiscoveryRequest) XXX_Unmarshal(b []byte) error

type SvcConfigDiscoveryRequestValidationError 

type SvcConfigDiscoveryRequestValidationError struct {
	// contains filtered or unexported fields
}

SvcConfigDiscoveryRequestValidationError is the validation error returned by SvcConfigDiscoveryRequest.Validate if the designated constraints aren't met.

func (SvcConfigDiscoveryRequestValidationError) Cause 

func (e SvcConfigDiscoveryRequestValidationError) Cause() error

Cause function returns cause value.

func (SvcConfigDiscoveryRequestValidationError) Error 

func (e SvcConfigDiscoveryRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SvcConfigDiscoveryRequestValidationError) ErrorName 

func (e SvcConfigDiscoveryRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SvcConfigDiscoveryRequestValidationError) Field 

func (e SvcConfigDiscoveryRequestValidationError) Field() string

Field function returns field value.

func (SvcConfigDiscoveryRequestValidationError) Key 

func (e SvcConfigDiscoveryRequestValidationError) Key() bool

Key function returns key value.

func (SvcConfigDiscoveryRequestValidationError) Reason 

func (e SvcConfigDiscoveryRequestValidationError) Reason() string

Reason function returns reason value.

type SvcConfigDiscoveryResponse 

type SvcConfigDiscoveryResponse struct {
	// Update of configuration.
	Updated              map[string]*service.Config `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*SvcConfigDiscoveryResponse) Descriptor 

func (*SvcConfigDiscoveryResponse) Descriptor() ([]byte, []int)

func (*SvcConfigDiscoveryResponse) Equal 

func (this *SvcConfigDiscoveryResponse) Equal(that interface{}) bool

func (*SvcConfigDiscoveryResponse) GetUpdated 

func (m *SvcConfigDiscoveryResponse) GetUpdated() map[string]*service.Config

func (*SvcConfigDiscoveryResponse) GoString 

func (this *SvcConfigDiscoveryResponse) GoString() string

func (*SvcConfigDiscoveryResponse) Marshal 

func (m *SvcConfigDiscoveryResponse) Marshal() (dAtA []byte, err error)

func (*SvcConfigDiscoveryResponse) MarshalJSON 

func (m *SvcConfigDiscoveryResponse) MarshalJSON() ([]byte, error)

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*SvcConfigDiscoveryResponse) MarshalTo 

func (m *SvcConfigDiscoveryResponse) MarshalTo(dAtA []byte) (int, error)

func (*SvcConfigDiscoveryResponse) MarshalToSizedBuffer 

func (m *SvcConfigDiscoveryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SvcConfigDiscoveryResponse) ProtoMessage 

func (*SvcConfigDiscoveryResponse) ProtoMessage()

func (*SvcConfigDiscoveryResponse) Reset 

func (m *SvcConfigDiscoveryResponse) Reset()

func (*SvcConfigDiscoveryResponse) Size 

func (m *SvcConfigDiscoveryResponse) Size() (n int)

func (*SvcConfigDiscoveryResponse) String 

func (m *SvcConfigDiscoveryResponse) String() string

func (*SvcConfigDiscoveryResponse) Unmarshal 

func (m *SvcConfigDiscoveryResponse) Unmarshal(dAtA []byte) error

func (*SvcConfigDiscoveryResponse) UnmarshalJSON 

func (m *SvcConfigDiscoveryResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*SvcConfigDiscoveryResponse) Validate 

func (m *SvcConfigDiscoveryResponse) Validate() error

Validate checks the field values on SvcConfigDiscoveryResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SvcConfigDiscoveryResponse) VerboseEqual 

func (this *SvcConfigDiscoveryResponse) VerboseEqual(that interface{}) error

func (*SvcConfigDiscoveryResponse) XXX_DiscardUnknown 

func (m *SvcConfigDiscoveryResponse) XXX_DiscardUnknown()

func (*SvcConfigDiscoveryResponse) XXX_Marshal 

func (m *SvcConfigDiscoveryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SvcConfigDiscoveryResponse) XXX_Merge 

func (m *SvcConfigDiscoveryResponse) XXX_Merge(src proto.Message)

func (*SvcConfigDiscoveryResponse) XXX_Size 

func (m *SvcConfigDiscoveryResponse) XXX_Size() int

func (*SvcConfigDiscoveryResponse) XXX_Unmarshal 

func (m *SvcConfigDiscoveryResponse) XXX_Unmarshal(b []byte) error

type SvcConfigDiscoveryResponseValidationError 

type SvcConfigDiscoveryResponseValidationError struct {
	// contains filtered or unexported fields
}

SvcConfigDiscoveryResponseValidationError is the validation error returned by SvcConfigDiscoveryResponse.Validate if the designated constraints aren't met.

func (SvcConfigDiscoveryResponseValidationError) Cause 

func (e SvcConfigDiscoveryResponseValidationError) Cause() error

Cause function returns cause value.

func (SvcConfigDiscoveryResponseValidationError) Error 

func (e SvcConfigDiscoveryResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SvcConfigDiscoveryResponseValidationError) ErrorName 

func (e SvcConfigDiscoveryResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SvcConfigDiscoveryResponseValidationError) Field 

func (e SvcConfigDiscoveryResponseValidationError) Field() string

Field function returns field value.

func (SvcConfigDiscoveryResponseValidationError) Key 

func (e SvcConfigDiscoveryResponseValidationError) Key() bool

Key function returns key value.

func (SvcConfigDiscoveryResponseValidationError) Reason 

func (e SvcConfigDiscoveryResponseValidationError) Reason() string

Reason function returns reason value.

type SvcEndpointDiscoveryRequest 

type SvcEndpointDiscoveryRequest struct {
	// All service names that need to subscribe.
	SvcNamesSubscribe []string `protobuf:"bytes,1,rep,name=svc_names_subscribe,json=svcNamesSubscribe,proto3" json:"svc_names_subscribe,omitempty"`
	// All service names that need to unsubscribe.
	SvcNamesUnsubscribe  []string `protobuf:"bytes,2,rep,name=svc_names_unsubscribe,json=svcNamesUnsubscribe,proto3" json:"svc_names_unsubscribe,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SvcEndpointDiscoveryRequest) Descriptor 

func (*SvcEndpointDiscoveryRequest) Descriptor() ([]byte, []int)

func (*SvcEndpointDiscoveryRequest) Equal 

func (this *SvcEndpointDiscoveryRequest) Equal(that interface{}) bool

func (*SvcEndpointDiscoveryRequest) GetSvcNamesSubscribe 

func (m *SvcEndpointDiscoveryRequest) GetSvcNamesSubscribe() []string

func (*SvcEndpointDiscoveryRequest) GetSvcNamesUnsubscribe 

func (m *SvcEndpointDiscoveryRequest) GetSvcNamesUnsubscribe() []string

func (*SvcEndpointDiscoveryRequest) GoString 

func (this *SvcEndpointDiscoveryRequest) GoString() string

func (*SvcEndpointDiscoveryRequest) Marshal 

func (m *SvcEndpointDiscoveryRequest) Marshal() (dAtA []byte, err error)

func (*SvcEndpointDiscoveryRequest) MarshalJSON 

func (m *SvcEndpointDiscoveryRequest) MarshalJSON() ([]byte, error)

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*SvcEndpointDiscoveryRequest) MarshalTo 

func (m *SvcEndpointDiscoveryRequest) MarshalTo(dAtA []byte) (int, error)

func (*SvcEndpointDiscoveryRequest) MarshalToSizedBuffer 

func (m *SvcEndpointDiscoveryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SvcEndpointDiscoveryRequest) ProtoMessage 

func (*SvcEndpointDiscoveryRequest) ProtoMessage()

func (*SvcEndpointDiscoveryRequest) Reset 

func (m *SvcEndpointDiscoveryRequest) Reset()

func (*SvcEndpointDiscoveryRequest) Size 

func (m *SvcEndpointDiscoveryRequest) Size() (n int)

func (*SvcEndpointDiscoveryRequest) String 

func (m *SvcEndpointDiscoveryRequest) String() string

func (*SvcEndpointDiscoveryRequest) Unmarshal 

func (m *SvcEndpointDiscoveryRequest) Unmarshal(dAtA []byte) error

func (*SvcEndpointDiscoveryRequest) UnmarshalJSON 

func (m *SvcEndpointDiscoveryRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*SvcEndpointDiscoveryRequest) Validate 

func (m *SvcEndpointDiscoveryRequest) Validate() error

Validate checks the field values on SvcEndpointDiscoveryRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SvcEndpointDiscoveryRequest) VerboseEqual 

func (this *SvcEndpointDiscoveryRequest) VerboseEqual(that interface{}) error

func (*SvcEndpointDiscoveryRequest) XXX_DiscardUnknown 

func (m *SvcEndpointDiscoveryRequest) XXX_DiscardUnknown()

func (*SvcEndpointDiscoveryRequest) XXX_Marshal 

func (m *SvcEndpointDiscoveryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SvcEndpointDiscoveryRequest) XXX_Merge 

func (m *SvcEndpointDiscoveryRequest) XXX_Merge(src proto.Message)

func (*SvcEndpointDiscoveryRequest) XXX_Size 

func (m *SvcEndpointDiscoveryRequest) XXX_Size() int

func (*SvcEndpointDiscoveryRequest) XXX_Unmarshal 

func (m *SvcEndpointDiscoveryRequest) XXX_Unmarshal(b []byte) error

type SvcEndpointDiscoveryRequestValidationError 

type SvcEndpointDiscoveryRequestValidationError struct {
	// contains filtered or unexported fields
}

SvcEndpointDiscoveryRequestValidationError is the validation error returned by SvcEndpointDiscoveryRequest.Validate if the designated constraints aren't met.

func (SvcEndpointDiscoveryRequestValidationError) Cause 

func (e SvcEndpointDiscoveryRequestValidationError) Cause() error

Cause function returns cause value.

func (SvcEndpointDiscoveryRequestValidationError) Error 

func (e SvcEndpointDiscoveryRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SvcEndpointDiscoveryRequestValidationError) ErrorName 

func (e SvcEndpointDiscoveryRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SvcEndpointDiscoveryRequestValidationError) Field 

func (e SvcEndpointDiscoveryRequestValidationError) Field() string

Field function returns field value.

func (SvcEndpointDiscoveryRequestValidationError) Key 

func (e SvcEndpointDiscoveryRequestValidationError) Key() bool

Key function returns key value.

func (SvcEndpointDiscoveryRequestValidationError) Reason 

func (e SvcEndpointDiscoveryRequestValidationError) Reason() string

Reason function returns reason value.

type SvcEndpointDiscoveryResponse 

type SvcEndpointDiscoveryResponse struct {
	// Name of service which endpoints had updated.
	SvcName string `protobuf:"bytes,1,opt,name=svc_name,json=svcName,proto3" json:"svc_name,omitempty"`
	// Added endpoints.
	Added []*service.Endpoint `protobuf:"bytes,2,rep,name=added,proto3" json:"added,omitempty"`
	// Removed endpoints.
	Removed              []*service.Endpoint `protobuf:"bytes,3,rep,name=removed,proto3" json:"removed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SvcEndpointDiscoveryResponse) Descriptor 

func (*SvcEndpointDiscoveryResponse) Descriptor() ([]byte, []int)

func (*SvcEndpointDiscoveryResponse) Equal 

func (this *SvcEndpointDiscoveryResponse) Equal(that interface{}) bool

func (*SvcEndpointDiscoveryResponse) GetAdded 

func (m *SvcEndpointDiscoveryResponse) GetAdded() []*service.Endpoint

func (*SvcEndpointDiscoveryResponse) GetRemoved 

func (m *SvcEndpointDiscoveryResponse) GetRemoved() []*service.Endpoint

func (*SvcEndpointDiscoveryResponse) GetSvcName 

func (m *SvcEndpointDiscoveryResponse) GetSvcName() string

func (*SvcEndpointDiscoveryResponse) GoString 

func (this *SvcEndpointDiscoveryResponse) GoString() string

func (*SvcEndpointDiscoveryResponse) Marshal 

func (m *SvcEndpointDiscoveryResponse) Marshal() (dAtA []byte, err error)

func (*SvcEndpointDiscoveryResponse) MarshalJSON 

func (m *SvcEndpointDiscoveryResponse) MarshalJSON() ([]byte, error)

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*SvcEndpointDiscoveryResponse) MarshalTo 

func (m *SvcEndpointDiscoveryResponse) MarshalTo(dAtA []byte) (int, error)

func (*SvcEndpointDiscoveryResponse) MarshalToSizedBuffer 

func (m *SvcEndpointDiscoveryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SvcEndpointDiscoveryResponse) ProtoMessage 

func (*SvcEndpointDiscoveryResponse) ProtoMessage()

func (*SvcEndpointDiscoveryResponse) Reset 

func (m *SvcEndpointDiscoveryResponse) Reset()

func (*SvcEndpointDiscoveryResponse) Size 

func (m *SvcEndpointDiscoveryResponse) Size() (n int)

func (*SvcEndpointDiscoveryResponse) String 

func (m *SvcEndpointDiscoveryResponse) String() string

func (*SvcEndpointDiscoveryResponse) Unmarshal 

func (m *SvcEndpointDiscoveryResponse) Unmarshal(dAtA []byte) error

func (*SvcEndpointDiscoveryResponse) UnmarshalJSON 

func (m *SvcEndpointDiscoveryResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*SvcEndpointDiscoveryResponse) Validate 

func (m *SvcEndpointDiscoveryResponse) Validate() error

Validate checks the field values on SvcEndpointDiscoveryResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SvcEndpointDiscoveryResponse) VerboseEqual 

func (this *SvcEndpointDiscoveryResponse) VerboseEqual(that interface{}) error

func (*SvcEndpointDiscoveryResponse) XXX_DiscardUnknown 

func (m *SvcEndpointDiscoveryResponse) XXX_DiscardUnknown()

func (*SvcEndpointDiscoveryResponse) XXX_Marshal 

func (m *SvcEndpointDiscoveryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SvcEndpointDiscoveryResponse) XXX_Merge 

func (m *SvcEndpointDiscoveryResponse) XXX_Merge(src proto.Message)

func (*SvcEndpointDiscoveryResponse) XXX_Size 

func (m *SvcEndpointDiscoveryResponse) XXX_Size() int

func (*SvcEndpointDiscoveryResponse) XXX_Unmarshal 

func (m *SvcEndpointDiscoveryResponse) XXX_Unmarshal(b []byte) error

type SvcEndpointDiscoveryResponseValidationError 

type SvcEndpointDiscoveryResponseValidationError struct {
	// contains filtered or unexported fields
}

SvcEndpointDiscoveryResponseValidationError is the validation error returned by SvcEndpointDiscoveryResponse.Validate if the designated constraints aren't met.

func (SvcEndpointDiscoveryResponseValidationError) Cause 

func (e SvcEndpointDiscoveryResponseValidationError) Cause() error

Cause function returns cause value.

func (SvcEndpointDiscoveryResponseValidationError) Error 

func (e SvcEndpointDiscoveryResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SvcEndpointDiscoveryResponseValidationError) ErrorName 

func (e SvcEndpointDiscoveryResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SvcEndpointDiscoveryResponseValidationError) Field 

func (e SvcEndpointDiscoveryResponseValidationError) Field() string

Field function returns field value.

func (SvcEndpointDiscoveryResponseValidationError) Key 

func (e SvcEndpointDiscoveryResponseValidationError) Key() bool

Key function returns key value.

func (SvcEndpointDiscoveryResponseValidationError) Reason 

func (e SvcEndpointDiscoveryResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedDiscoveryServiceServer 

type UnimplementedDiscoveryServiceServer struct {
}

UnimplementedDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDiscoveryServiceServer) StreamDependencies 

func (*UnimplementedDiscoveryServiceServer) StreamDependencies(req *DependencyDiscoveryRequest, srv DiscoveryService_StreamDependenciesServer) error

func (*UnimplementedDiscoveryServiceServer) StreamSvcConfigs 

func (*UnimplementedDiscoveryServiceServer) StreamSvcConfigs(srv DiscoveryService_StreamSvcConfigsServer) error

func (*UnimplementedDiscoveryServiceServer) StreamSvcEndpoints 

func (*UnimplementedDiscoveryServiceServer) StreamSvcEndpoints(srv DiscoveryService_StreamSvcEndpointsServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.