operator

package
v1.3.0-rc.2 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 2021 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_dapr_proto_operator_v1_operator_proto protoreflect.FileDescriptor
View Source 
var Operator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.operator.v1.Operator",
	HandlerType: (*OperatorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListComponents",
			Handler:    _Operator_ListComponents_Handler,
		},
		{
			MethodName: "GetConfiguration",
			Handler:    _Operator_GetConfiguration_Handler,
		},
		{
			MethodName: "ListSubscriptions",
			Handler:    _Operator_ListSubscriptions_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ComponentUpdate",
			Handler:       _Operator_ComponentUpdate_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "dapr/proto/operator/v1/operator.proto",
}

Operator_ServiceDesc is the grpc.ServiceDesc for Operator service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOperatorServer 

func RegisterOperatorServer(s grpc.ServiceRegistrar, srv OperatorServer)

Types

type ComponentUpdateEvent 

type ComponentUpdateEvent struct {
	Component []byte `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"`
	// contains filtered or unexported fields
}

ComponentUpdateEvent includes the updated component event.

func (*ComponentUpdateEvent) Descriptor deprecated 

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

Deprecated: Use ComponentUpdateEvent.ProtoReflect.Descriptor instead.

func (*ComponentUpdateEvent) GetComponent 

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

func (*ComponentUpdateEvent) ProtoMessage 

func (*ComponentUpdateEvent) ProtoMessage()

func (*ComponentUpdateEvent) ProtoReflect added in v1.0.0 

func (x *ComponentUpdateEvent) ProtoReflect() protoreflect.Message

func (*ComponentUpdateEvent) Reset 

func (x *ComponentUpdateEvent) Reset()

func (*ComponentUpdateEvent) String 

func (x *ComponentUpdateEvent) String() string

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"`
	// contains filtered or unexported fields
}

GetConfigurationRequest is the request message to get the configuration.

func (*GetConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use GetConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationRequest) GetName 

func (x *GetConfigurationRequest) GetName() string

func (*GetConfigurationRequest) GetNamespace 

func (x *GetConfigurationRequest) GetNamespace() string

func (*GetConfigurationRequest) ProtoMessage 

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) ProtoReflect added in v1.0.0 

func (x *GetConfigurationRequest) ProtoReflect() protoreflect.Message

func (*GetConfigurationRequest) Reset 

func (x *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) String 

func (x *GetConfigurationRequest) String() string

type GetConfigurationResponse 

type GetConfigurationResponse struct {
	Configuration []byte `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// contains filtered or unexported fields
}

GetConfigurationResponse includes the requested configuration.

func (*GetConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use GetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse) GetConfiguration 

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

func (*GetConfigurationResponse) ProtoMessage 

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) ProtoReflect added in v1.0.0 

func (x *GetConfigurationResponse) ProtoReflect() protoreflect.Message

func (*GetConfigurationResponse) Reset 

func (x *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) String 

func (x *GetConfigurationResponse) String() string

type ListComponentResponse added in v0.8.0 

type ListComponentResponse struct {
	Components [][]byte `protobuf:"bytes,1,rep,name=components,proto3" json:"components,omitempty"`
	// contains filtered or unexported fields
}

ListComponentResponse includes the list of available components.

func (*ListComponentResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ListComponentResponse.ProtoReflect.Descriptor instead.

func (*ListComponentResponse) GetComponents added in v0.8.0 

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

func (*ListComponentResponse) ProtoMessage added in v0.8.0 

func (*ListComponentResponse) ProtoMessage()

func (*ListComponentResponse) ProtoReflect added in v1.0.0 

func (x *ListComponentResponse) ProtoReflect() protoreflect.Message

func (*ListComponentResponse) Reset added in v0.8.0 

func (x *ListComponentResponse) Reset()

func (*ListComponentResponse) String added in v0.8.0 

func (x *ListComponentResponse) String() string

type ListSubscriptionsResponse added in v0.11.0 

type ListSubscriptionsResponse struct {
	Subscriptions [][]byte `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

ListSubscriptionsResponse includes pub/sub subscriptions.

func (*ListSubscriptionsResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use ListSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsResponse) GetSubscriptions added in v0.11.0 

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

func (*ListSubscriptionsResponse) ProtoMessage added in v0.11.0 

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) ProtoReflect added in v1.0.0 

func (x *ListSubscriptionsResponse) ProtoReflect() protoreflect.Message

func (*ListSubscriptionsResponse) Reset added in v0.11.0 

func (x *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) String added in v0.11.0 

func (x *ListSubscriptionsResponse) String() string

type OperatorClient 

type OperatorClient interface {
	// Sends events to Dapr sidecars upon component changes.
	ComponentUpdate(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Operator_ComponentUpdateClient, error)
	// Returns a list of available components
	ListComponents(ctx context.Context, in *emptypb.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 *emptypb.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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOperatorClient 

func NewOperatorClient(cc grpc.ClientConnInterface) OperatorClient

type OperatorServer 

type OperatorServer interface {
	// Sends events to Dapr sidecars upon component changes.
	ComponentUpdate(*emptypb.Empty, Operator_ComponentUpdateServer) error
	// Returns a list of available components
	ListComponents(context.Context, *emptypb.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, *emptypb.Empty) (*ListSubscriptionsResponse, error)
}

OperatorServer is the server API for Operator service. All implementations should embed UnimplementedOperatorServer for forward compatibility

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 should be embedded to have forward compatible implementations.

func (UnimplementedOperatorServer) ComponentUpdate 

func (UnimplementedOperatorServer) ComponentUpdate(*emptypb.Empty, Operator_ComponentUpdateServer) error

func (UnimplementedOperatorServer) GetConfiguration 

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

func (UnimplementedOperatorServer) ListComponents added in v0.8.0 

func (UnimplementedOperatorServer) ListComponents(context.Context, *emptypb.Empty) (*ListComponentResponse, error)

func (UnimplementedOperatorServer) ListSubscriptions added in v0.11.0 

func (UnimplementedOperatorServer) ListSubscriptions(context.Context, *emptypb.Empty) (*ListSubscriptionsResponse, error)

type UnsafeOperatorServer added in v1.0.0 

type UnsafeOperatorServer interface {
	// contains filtered or unexported methods
}

UnsafeOperatorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OperatorServer will result in compilation errors.

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.