operator

package
v0.11.0-rc.3 Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2020 License: MIT Imports: 8 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            []byte   `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ComponentUpdateEvent includes the updated component event.

func (*ComponentUpdateEvent) Descriptor 

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

func (*ComponentUpdateEvent) GetComponent 

func (m *ComponentUpdateEvent) GetComponent() []byte

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 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:"-"`
}

GetConfigurationRequest is the request message to get the configuration.

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        []byte   `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetConfigurationResponse includes the requested configuration.

func (*GetConfigurationResponse) Descriptor 

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

func (*GetConfigurationResponse) GetConfiguration 

func (m *GetConfigurationResponse) GetConfiguration() []byte

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 ListComponentResponse added in v0.8.0 

type ListComponentResponse struct {
	Components           [][]byte `protobuf:"bytes,1,rep,name=components,proto3" json:"components,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListComponentResponse includes the list of available components.

func (*ListComponentResponse) Descriptor added in v0.8.0 

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

func (*ListComponentResponse) GetComponents added in v0.8.0 

func (m *ListComponentResponse) GetComponents() [][]byte

func (*ListComponentResponse) ProtoMessage added in v0.8.0 

func (*ListComponentResponse) ProtoMessage()

func (*ListComponentResponse) Reset added in v0.8.0 

func (m *ListComponentResponse) Reset()

func (*ListComponentResponse) String added in v0.8.0 

func (m *ListComponentResponse) String() string

func (*ListComponentResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *ListComponentResponse) XXX_DiscardUnknown()

func (*ListComponentResponse) XXX_Marshal added in v0.8.0 

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

func (*ListComponentResponse) XXX_Merge added in v0.8.0 

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

func (*ListComponentResponse) XXX_Size added in v0.8.0 

func (m *ListComponentResponse) XXX_Size() int

func (*ListComponentResponse) XXX_Unmarshal added in v0.8.0 

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

type ListSubscriptionsResponse added in v0.11.0 

type ListSubscriptionsResponse struct {
	Subscriptions        [][]byte `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListSubscriptionsResponse includes pub/sub subscriptions.

func (*ListSubscriptionsResponse) Descriptor added in v0.11.0 

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

func (*ListSubscriptionsResponse) GetSubscriptions added in v0.11.0 

func (m *ListSubscriptionsResponse) GetSubscriptions() [][]byte

func (*ListSubscriptionsResponse) ProtoMessage added in v0.11.0 

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) Reset added in v0.11.0 

func (m *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) String added in v0.11.0 

func (m *ListSubscriptionsResponse) String() string

func (*ListSubscriptionsResponse) XXX_DiscardUnknown added in v0.11.0 

func (m *ListSubscriptionsResponse) XXX_DiscardUnknown()

func (*ListSubscriptionsResponse) XXX_Marshal added in v0.11.0 

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

func (*ListSubscriptionsResponse) XXX_Merge added in v0.11.0 

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

func (*ListSubscriptionsResponse) XXX_Size added in v0.11.0 

func (m *ListSubscriptionsResponse) XXX_Size() int

func (*ListSubscriptionsResponse) XXX_Unmarshal added in v0.11.0 

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

type OperatorClient 

type OperatorClient interface {
	// Sends events to Dapr sidecars upon component changes.
	ComponentUpdate(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (Operator_ComponentUpdateClient, error)
	// Returns a list of available components
	ListComponents(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListComponentResponse, error)
	// Returns a given configuration by name
	GetConfiguration(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationResponse, error)
	// Returns a list of pub/sub subscriptions
	ListSubscriptions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListSubscriptionsResponse, 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 {
	// Sends events to Dapr sidecars upon component changes.
	ComponentUpdate(*empty.Empty, Operator_ComponentUpdateServer) error
	// Returns a list of available components
	ListComponents(context.Context, *empty.Empty) (*ListComponentResponse, error)
	// Returns a given configuration by name
	GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)
	// Returns a list of pub/sub subscriptions
	ListSubscriptions(context.Context, *empty.Empty) (*ListSubscriptionsResponse, 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) GetConfiguration 

func (*UnimplementedOperatorServer) GetConfiguration(ctx context.Context, req *GetConfigurationRequest) (*GetConfigurationResponse, error)

func (*UnimplementedOperatorServer) ListComponents added in v0.8.0 

func (*UnimplementedOperatorServer) ListComponents(ctx context.Context, req *empty.Empty) (*ListComponentResponse, error)

func (*UnimplementedOperatorServer) ListSubscriptions added in v0.11.0 

func (*UnimplementedOperatorServer) ListSubscriptions(ctx context.Context, req *empty.Empty) (*ListSubscriptionsResponse, 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.