Documentation
¶
Index ¶
- func RegisterOperatorServer(s *grpc.Server, srv OperatorServer)
- type ComponentUpdateEvent
- func (*ComponentUpdateEvent) Descriptor() ([]byte, []int)
- func (m *ComponentUpdateEvent) GetComponent() *any.Any
- func (*ComponentUpdateEvent) ProtoMessage()
- func (m *ComponentUpdateEvent) Reset()
- func (m *ComponentUpdateEvent) String() string
- func (m *ComponentUpdateEvent) XXX_DiscardUnknown()
- func (m *ComponentUpdateEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ComponentUpdateEvent) XXX_Merge(src proto.Message)
- func (m *ComponentUpdateEvent) XXX_Size() int
- func (m *ComponentUpdateEvent) XXX_Unmarshal(b []byte) error
- type GetComponentResponse
- func (*GetComponentResponse) Descriptor() ([]byte, []int)
- func (m *GetComponentResponse) GetComponents() []*any.Any
- func (*GetComponentResponse) ProtoMessage()
- func (m *GetComponentResponse) Reset()
- func (m *GetComponentResponse) String() string
- func (m *GetComponentResponse) XXX_DiscardUnknown()
- func (m *GetComponentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetComponentResponse) XXX_Merge(src proto.Message)
- func (m *GetComponentResponse) XXX_Size() int
- func (m *GetComponentResponse) XXX_Unmarshal(b []byte) error
- type GetConfigurationRequest
- func (*GetConfigurationRequest) Descriptor() ([]byte, []int)
- func (m *GetConfigurationRequest) GetName() string
- func (m *GetConfigurationRequest) GetNamespace() string
- func (*GetConfigurationRequest) ProtoMessage()
- func (m *GetConfigurationRequest) Reset()
- func (m *GetConfigurationRequest) String() string
- func (m *GetConfigurationRequest) XXX_DiscardUnknown()
- func (m *GetConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetConfigurationRequest) XXX_Merge(src proto.Message)
- func (m *GetConfigurationRequest) XXX_Size() int
- func (m *GetConfigurationRequest) XXX_Unmarshal(b []byte) error
- type GetConfigurationResponse
- func (*GetConfigurationResponse) Descriptor() ([]byte, []int)
- func (m *GetConfigurationResponse) GetConfiguration() *any.Any
- func (*GetConfigurationResponse) ProtoMessage()
- func (m *GetConfigurationResponse) Reset()
- func (m *GetConfigurationResponse) String() string
- func (m *GetConfigurationResponse) XXX_DiscardUnknown()
- func (m *GetConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetConfigurationResponse) XXX_Merge(src proto.Message)
- func (m *GetConfigurationResponse) XXX_Size() int
- func (m *GetConfigurationResponse) XXX_Unmarshal(b []byte) error
- type OperatorClient
- type OperatorServer
- type Operator_ComponentUpdateClient
- type Operator_ComponentUpdateServer
- type UnimplementedOperatorServer
- func (*UnimplementedOperatorServer) ComponentUpdate(req *empty.Empty, srv Operator_ComponentUpdateServer) error
- func (*UnimplementedOperatorServer) GetComponents(ctx context.Context, req *empty.Empty) (*GetComponentResponse, error)
- func (*UnimplementedOperatorServer) GetConfiguration(ctx context.Context, req *GetConfigurationRequest) (*GetConfigurationResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterOperatorServer ¶
func RegisterOperatorServer(s *grpc.Server, srv OperatorServer)
Types ¶
type ComponentUpdateEvent ¶
type ComponentUpdateEvent struct {
Component *any.Any `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ComponentUpdateEvent) Descriptor ¶
func (*ComponentUpdateEvent) Descriptor() ([]byte, []int)
func (*ComponentUpdateEvent) GetComponent ¶
func (m *ComponentUpdateEvent) GetComponent() *any.Any
func (*ComponentUpdateEvent) ProtoMessage ¶
func (*ComponentUpdateEvent) ProtoMessage()
func (*ComponentUpdateEvent) Reset ¶
func (m *ComponentUpdateEvent) Reset()
func (*ComponentUpdateEvent) String ¶
func (m *ComponentUpdateEvent) String() string
func (*ComponentUpdateEvent) XXX_DiscardUnknown ¶
func (m *ComponentUpdateEvent) XXX_DiscardUnknown()
func (*ComponentUpdateEvent) XXX_Marshal ¶
func (m *ComponentUpdateEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ComponentUpdateEvent) XXX_Merge ¶
func (m *ComponentUpdateEvent) XXX_Merge(src proto.Message)
func (*ComponentUpdateEvent) XXX_Size ¶
func (m *ComponentUpdateEvent) XXX_Size() int
func (*ComponentUpdateEvent) XXX_Unmarshal ¶
func (m *ComponentUpdateEvent) XXX_Unmarshal(b []byte) error
type GetComponentResponse ¶
type GetComponentResponse struct {
Components []*any.Any `protobuf:"bytes,1,rep,name=components,proto3" json:"components,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*GetComponentResponse) Descriptor ¶
func (*GetComponentResponse) Descriptor() ([]byte, []int)
func (*GetComponentResponse) GetComponents ¶
func (m *GetComponentResponse) GetComponents() []*any.Any
func (*GetComponentResponse) ProtoMessage ¶
func (*GetComponentResponse) ProtoMessage()
func (*GetComponentResponse) Reset ¶
func (m *GetComponentResponse) Reset()
func (*GetComponentResponse) String ¶
func (m *GetComponentResponse) String() string
func (*GetComponentResponse) XXX_DiscardUnknown ¶
func (m *GetComponentResponse) XXX_DiscardUnknown()
func (*GetComponentResponse) XXX_Marshal ¶
func (m *GetComponentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetComponentResponse) XXX_Merge ¶
func (m *GetComponentResponse) XXX_Merge(src proto.Message)
func (*GetComponentResponse) XXX_Size ¶
func (m *GetComponentResponse) XXX_Size() int
func (*GetComponentResponse) XXX_Unmarshal ¶
func (m *GetComponentResponse) XXX_Unmarshal(b []byte) error
type GetConfigurationRequest ¶
type GetConfigurationRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*GetConfigurationRequest) Descriptor ¶
func (*GetConfigurationRequest) Descriptor() ([]byte, []int)
func (*GetConfigurationRequest) GetName ¶
func (m *GetConfigurationRequest) GetName() string
func (*GetConfigurationRequest) GetNamespace ¶
func (m *GetConfigurationRequest) GetNamespace() string
func (*GetConfigurationRequest) ProtoMessage ¶
func (*GetConfigurationRequest) ProtoMessage()
func (*GetConfigurationRequest) Reset ¶
func (m *GetConfigurationRequest) Reset()
func (*GetConfigurationRequest) String ¶
func (m *GetConfigurationRequest) String() string
func (*GetConfigurationRequest) XXX_DiscardUnknown ¶
func (m *GetConfigurationRequest) XXX_DiscardUnknown()
func (*GetConfigurationRequest) XXX_Marshal ¶
func (m *GetConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetConfigurationRequest) XXX_Merge ¶
func (m *GetConfigurationRequest) XXX_Merge(src proto.Message)
func (*GetConfigurationRequest) XXX_Size ¶
func (m *GetConfigurationRequest) XXX_Size() int
func (*GetConfigurationRequest) XXX_Unmarshal ¶
func (m *GetConfigurationRequest) XXX_Unmarshal(b []byte) error
type GetConfigurationResponse ¶
type GetConfigurationResponse struct {
Configuration *any.Any `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*GetConfigurationResponse) Descriptor ¶
func (*GetConfigurationResponse) Descriptor() ([]byte, []int)
func (*GetConfigurationResponse) GetConfiguration ¶
func (m *GetConfigurationResponse) GetConfiguration() *any.Any
func (*GetConfigurationResponse) ProtoMessage ¶
func (*GetConfigurationResponse) ProtoMessage()
func (*GetConfigurationResponse) Reset ¶
func (m *GetConfigurationResponse) Reset()
func (*GetConfigurationResponse) String ¶
func (m *GetConfigurationResponse) String() string
func (*GetConfigurationResponse) XXX_DiscardUnknown ¶
func (m *GetConfigurationResponse) XXX_DiscardUnknown()
func (*GetConfigurationResponse) XXX_Marshal ¶
func (m *GetConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetConfigurationResponse) XXX_Merge ¶
func (m *GetConfigurationResponse) XXX_Merge(src proto.Message)
func (*GetConfigurationResponse) XXX_Size ¶
func (m *GetConfigurationResponse) XXX_Size() int
func (*GetConfigurationResponse) XXX_Unmarshal ¶
func (m *GetConfigurationResponse) XXX_Unmarshal(b []byte) error
type OperatorClient ¶
type OperatorClient interface {
// ComponentUpdate sends events to Dapr sidecars upon component changes.
ComponentUpdate(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (Operator_ComponentUpdateClient, error)
// GetComponents returns a list of available components
GetComponents(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetComponentResponse, error)
// GetConfiguration returns a given configuration by name
GetConfiguration(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationResponse, error)
}
OperatorClient is the client API for Operator service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOperatorClient ¶
func NewOperatorClient(cc *grpc.ClientConn) OperatorClient
type OperatorServer ¶
type OperatorServer interface {
// ComponentUpdate sends events to Dapr sidecars upon component changes.
ComponentUpdate(*empty.Empty, Operator_ComponentUpdateServer) error
// GetComponents returns a list of available components
GetComponents(context.Context, *empty.Empty) (*GetComponentResponse, error)
// GetConfiguration returns a given configuration by name
GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)
}
OperatorServer is the server API for Operator service.
type Operator_ComponentUpdateClient ¶
type Operator_ComponentUpdateClient interface {
Recv() (*ComponentUpdateEvent, error)
grpc.ClientStream
}
type Operator_ComponentUpdateServer ¶
type Operator_ComponentUpdateServer interface {
Send(*ComponentUpdateEvent) error
grpc.ServerStream
}
type UnimplementedOperatorServer ¶
type UnimplementedOperatorServer struct {
}
UnimplementedOperatorServer can be embedded to have forward compatible implementations.
func (*UnimplementedOperatorServer) ComponentUpdate ¶
func (*UnimplementedOperatorServer) ComponentUpdate(req *empty.Empty, srv Operator_ComponentUpdateServer) error
func (*UnimplementedOperatorServer) GetComponents ¶
func (*UnimplementedOperatorServer) GetComponents(ctx context.Context, req *empty.Empty) (*GetComponentResponse, error)
func (*UnimplementedOperatorServer) GetConfiguration ¶
func (*UnimplementedOperatorServer) GetConfiguration(ctx context.Context, req *GetConfigurationRequest) (*GetConfigurationResponse, error)
Click to show internal directories.
Click to hide internal directories.