operator

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Index

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)

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.