operator

package
v1.13.1 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ResourceEventType_name = map[int32]string{
		0: "UNKNOWN",
		1: "CREATED",
		2: "UPDATED",
		3: "DELETED",
	}
	ResourceEventType_value = map[string]int32{
		"UNKNOWN": 0,
		"CREATED": 1,
		"UPDATED": 2,
		"DELETED": 3,
	}
)

Enum value maps for ResourceEventType.

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,
		},
		{
			MethodName: "GetResiliency",
			Handler:    _Operator_GetResiliency_Handler,
		},
		{
			MethodName: "ListResiliency",
			Handler:    _Operator_ListResiliency_Handler,
		},
		{
			MethodName: "ListSubscriptionsV2",
			Handler:    _Operator_ListSubscriptionsV2_Handler,
		},
		{
			MethodName: "ListHTTPEndpoints",
			Handler:    _Operator_ListHTTPEndpoints_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ComponentUpdate",
			Handler:       _Operator_ComponentUpdate_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "HTTPEndpointUpdate",
			Handler:       _Operator_HTTPEndpointUpdate_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"`
	// type is the type of event.
	Type ResourceEventType `protobuf:"varint,2,opt,name=type,proto3,enum=dapr.proto.operator.v1.ResourceEventType" json:"type,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) GetType added in v1.13.0 

func (x *ComponentUpdateEvent) GetType() ResourceEventType

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 ComponentUpdateRequest added in v1.4.0 

type ComponentUpdateRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PodName   string `protobuf:"bytes,2,opt,name=podName,proto3" json:"podName,omitempty"`
	// contains filtered or unexported fields
}

ComponentUpdateRequest is the request to get updates about new components for a given namespace.

func (*ComponentUpdateRequest) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use ComponentUpdateRequest.ProtoReflect.Descriptor instead.

func (*ComponentUpdateRequest) GetNamespace added in v1.4.0 

func (x *ComponentUpdateRequest) GetNamespace() string

func (*ComponentUpdateRequest) GetPodName added in v1.7.0 

func (x *ComponentUpdateRequest) GetPodName() string

func (*ComponentUpdateRequest) ProtoMessage added in v1.4.0 

func (*ComponentUpdateRequest) ProtoMessage()

func (*ComponentUpdateRequest) ProtoReflect added in v1.4.0 

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

func (*ComponentUpdateRequest) Reset added in v1.4.0 

func (x *ComponentUpdateRequest) Reset()

func (*ComponentUpdateRequest) String added in v1.4.0 

func (x *ComponentUpdateRequest) 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"`
	PodName   string `protobuf:"bytes,3,opt,name=podName,proto3" json:"podName,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) GetPodName added in v1.7.0 

func (x *GetConfigurationRequest) GetPodName() 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 GetHTTPEndpointRequest added in v1.11.0 

type GetHTTPEndpointRequest 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
}

GetHTTPEndpointRequest is the request to get an http endpoint configuration.

func (*GetHTTPEndpointRequest) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use GetHTTPEndpointRequest.ProtoReflect.Descriptor instead.

func (*GetHTTPEndpointRequest) GetName added in v1.11.0 

func (x *GetHTTPEndpointRequest) GetName() string

func (*GetHTTPEndpointRequest) GetNamespace added in v1.11.0 

func (x *GetHTTPEndpointRequest) GetNamespace() string

func (*GetHTTPEndpointRequest) ProtoMessage added in v1.11.0 

func (*GetHTTPEndpointRequest) ProtoMessage()

func (*GetHTTPEndpointRequest) ProtoReflect added in v1.11.0 

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

func (*GetHTTPEndpointRequest) Reset added in v1.11.0 

func (x *GetHTTPEndpointRequest) Reset()

func (*GetHTTPEndpointRequest) String added in v1.11.0 

func (x *GetHTTPEndpointRequest) String() string

type GetHTTPEndpointResponse added in v1.11.0 

type GetHTTPEndpointResponse struct {
	HttpEndpoint []byte `protobuf:"bytes,1,opt,name=http_endpoint,json=httpEndpoint,proto3" json:"http_endpoint,omitempty"`
	// contains filtered or unexported fields
}

GetHTTPEndpointResponse includes the requested http endpoint configuration.

func (*GetHTTPEndpointResponse) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use GetHTTPEndpointResponse.ProtoReflect.Descriptor instead.

func (*GetHTTPEndpointResponse) GetHttpEndpoint added in v1.11.0 

func (x *GetHTTPEndpointResponse) GetHttpEndpoint() []byte

func (*GetHTTPEndpointResponse) ProtoMessage added in v1.11.0 

func (*GetHTTPEndpointResponse) ProtoMessage()

func (*GetHTTPEndpointResponse) ProtoReflect added in v1.11.0 

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

func (*GetHTTPEndpointResponse) Reset added in v1.11.0 

func (x *GetHTTPEndpointResponse) Reset()

func (*GetHTTPEndpointResponse) String added in v1.11.0 

func (x *GetHTTPEndpointResponse) String() string

type GetResiliencyRequest added in v1.7.0 

type GetResiliencyRequest 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
}

GetResiliencyRequest is the request to get a resiliency configuration.

func (*GetResiliencyRequest) Descriptor deprecated added in v1.7.0 

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

Deprecated: Use GetResiliencyRequest.ProtoReflect.Descriptor instead.

func (*GetResiliencyRequest) GetName added in v1.7.0 

func (x *GetResiliencyRequest) GetName() string

func (*GetResiliencyRequest) GetNamespace added in v1.7.0 

func (x *GetResiliencyRequest) GetNamespace() string

func (*GetResiliencyRequest) ProtoMessage added in v1.7.0 

func (*GetResiliencyRequest) ProtoMessage()

func (*GetResiliencyRequest) ProtoReflect added in v1.7.0 

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

func (*GetResiliencyRequest) Reset added in v1.7.0 

func (x *GetResiliencyRequest) Reset()

func (*GetResiliencyRequest) String added in v1.7.0 

func (x *GetResiliencyRequest) String() string

type GetResiliencyResponse added in v1.7.0 

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

GetResiliencyResponse includes the requested resiliency configuration.

func (*GetResiliencyResponse) Descriptor deprecated added in v1.7.0 

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

Deprecated: Use GetResiliencyResponse.ProtoReflect.Descriptor instead.

func (*GetResiliencyResponse) GetResiliency added in v1.7.0 

func (x *GetResiliencyResponse) GetResiliency() []byte

func (*GetResiliencyResponse) ProtoMessage added in v1.7.0 

func (*GetResiliencyResponse) ProtoMessage()

func (*GetResiliencyResponse) ProtoReflect added in v1.7.0 

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

func (*GetResiliencyResponse) Reset added in v1.7.0 

func (x *GetResiliencyResponse) Reset()

func (*GetResiliencyResponse) String added in v1.7.0 

func (x *GetResiliencyResponse) String() string

type HTTPEndpointUpdateEvent added in v1.11.0 

type HTTPEndpointUpdateEvent struct {
	HttpEndpoints []byte `protobuf:"bytes,1,opt,name=http_endpoints,json=httpEndpoints,proto3" json:"http_endpoints,omitempty"`
	// contains filtered or unexported fields
}

HTTPEndpointsUpdateEvent includes the updated http endpoint event.

func (*HTTPEndpointUpdateEvent) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use HTTPEndpointUpdateEvent.ProtoReflect.Descriptor instead.

func (*HTTPEndpointUpdateEvent) GetHttpEndpoints added in v1.11.0 

func (x *HTTPEndpointUpdateEvent) GetHttpEndpoints() []byte

func (*HTTPEndpointUpdateEvent) ProtoMessage added in v1.11.0 

func (*HTTPEndpointUpdateEvent) ProtoMessage()

func (*HTTPEndpointUpdateEvent) ProtoReflect added in v1.11.0 

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

func (*HTTPEndpointUpdateEvent) Reset added in v1.11.0 

func (x *HTTPEndpointUpdateEvent) Reset()

func (*HTTPEndpointUpdateEvent) String added in v1.11.0 

func (x *HTTPEndpointUpdateEvent) String() string

type HTTPEndpointUpdateRequest added in v1.11.0 

type HTTPEndpointUpdateRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PodName   string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	// contains filtered or unexported fields
}

HTTPEndpointsUpdateRequest is the request to get updates about new http endpoints for a given namespace.

func (*HTTPEndpointUpdateRequest) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use HTTPEndpointUpdateRequest.ProtoReflect.Descriptor instead.

func (*HTTPEndpointUpdateRequest) GetNamespace added in v1.11.0 

func (x *HTTPEndpointUpdateRequest) GetNamespace() string

func (*HTTPEndpointUpdateRequest) GetPodName added in v1.11.0 

func (x *HTTPEndpointUpdateRequest) GetPodName() string

func (*HTTPEndpointUpdateRequest) ProtoMessage added in v1.11.0 

func (*HTTPEndpointUpdateRequest) ProtoMessage()

func (*HTTPEndpointUpdateRequest) ProtoReflect added in v1.11.0 

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

func (*HTTPEndpointUpdateRequest) Reset added in v1.11.0 

func (x *HTTPEndpointUpdateRequest) Reset()

func (*HTTPEndpointUpdateRequest) String added in v1.11.0 

func (x *HTTPEndpointUpdateRequest) 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 ListComponentsRequest added in v1.4.0 

type ListComponentsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PodName   string `protobuf:"bytes,2,opt,name=podName,proto3" json:"podName,omitempty"`
	// contains filtered or unexported fields
}

ListComponentsRequest is the request to get components for a sidecar in namespace.

func (*ListComponentsRequest) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use ListComponentsRequest.ProtoReflect.Descriptor instead.

func (*ListComponentsRequest) GetNamespace added in v1.4.0 

func (x *ListComponentsRequest) GetNamespace() string

func (*ListComponentsRequest) GetPodName added in v1.7.0 

func (x *ListComponentsRequest) GetPodName() string

func (*ListComponentsRequest) ProtoMessage added in v1.4.0 

func (*ListComponentsRequest) ProtoMessage()

func (*ListComponentsRequest) ProtoReflect added in v1.4.0 

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

func (*ListComponentsRequest) Reset added in v1.4.0 

func (x *ListComponentsRequest) Reset()

func (*ListComponentsRequest) String added in v1.4.0 

func (x *ListComponentsRequest) String() string

type ListHTTPEndpointsRequest added in v1.11.0 

type ListHTTPEndpointsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ListHTTPEndpointsRequest) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use ListHTTPEndpointsRequest.ProtoReflect.Descriptor instead.

func (*ListHTTPEndpointsRequest) GetNamespace added in v1.11.0 

func (x *ListHTTPEndpointsRequest) GetNamespace() string

func (*ListHTTPEndpointsRequest) ProtoMessage added in v1.11.0 

func (*ListHTTPEndpointsRequest) ProtoMessage()

func (*ListHTTPEndpointsRequest) ProtoReflect added in v1.11.0 

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

func (*ListHTTPEndpointsRequest) Reset added in v1.11.0 

func (x *ListHTTPEndpointsRequest) Reset()

func (*ListHTTPEndpointsRequest) String added in v1.11.0 

func (x *ListHTTPEndpointsRequest) String() string

type ListHTTPEndpointsResponse added in v1.11.0 

type ListHTTPEndpointsResponse struct {
	HttpEndpoints [][]byte `protobuf:"bytes,1,rep,name=http_endpoints,json=httpEndpoints,proto3" json:"http_endpoints,omitempty"`
	// contains filtered or unexported fields
}

ListHTTPEndpointsResponse includes the list of available http endpoint configurations.

func (*ListHTTPEndpointsResponse) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use ListHTTPEndpointsResponse.ProtoReflect.Descriptor instead.

func (*ListHTTPEndpointsResponse) GetHttpEndpoints added in v1.11.0 

func (x *ListHTTPEndpointsResponse) GetHttpEndpoints() [][]byte

func (*ListHTTPEndpointsResponse) ProtoMessage added in v1.11.0 

func (*ListHTTPEndpointsResponse) ProtoMessage()

func (*ListHTTPEndpointsResponse) ProtoReflect added in v1.11.0 

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

func (*ListHTTPEndpointsResponse) Reset added in v1.11.0 

func (x *ListHTTPEndpointsResponse) Reset()

func (*ListHTTPEndpointsResponse) String added in v1.11.0 

func (x *ListHTTPEndpointsResponse) String() string

type ListResiliencyRequest added in v1.7.0 

type ListResiliencyRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

ListResiliencyRequest is the requests to get resiliency configurations for a sidecar namespace.

func (*ListResiliencyRequest) Descriptor deprecated added in v1.7.0 

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

Deprecated: Use ListResiliencyRequest.ProtoReflect.Descriptor instead.

func (*ListResiliencyRequest) GetNamespace added in v1.7.0 

func (x *ListResiliencyRequest) GetNamespace() string

func (*ListResiliencyRequest) ProtoMessage added in v1.7.0 

func (*ListResiliencyRequest) ProtoMessage()

func (*ListResiliencyRequest) ProtoReflect added in v1.7.0 

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

func (*ListResiliencyRequest) Reset added in v1.7.0 

func (x *ListResiliencyRequest) Reset()

func (*ListResiliencyRequest) String added in v1.7.0 

func (x *ListResiliencyRequest) String() string

type ListResiliencyResponse added in v1.7.0 

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

ListResiliencyResponse includes the list of available resiliency configurations.

func (*ListResiliencyResponse) Descriptor deprecated added in v1.7.0 

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

Deprecated: Use ListResiliencyResponse.ProtoReflect.Descriptor instead.

func (*ListResiliencyResponse) GetResiliencies added in v1.7.0 

func (x *ListResiliencyResponse) GetResiliencies() [][]byte

func (*ListResiliencyResponse) ProtoMessage added in v1.7.0 

func (*ListResiliencyResponse) ProtoMessage()

func (*ListResiliencyResponse) ProtoReflect added in v1.7.0 

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

func (*ListResiliencyResponse) Reset added in v1.7.0 

func (x *ListResiliencyResponse) Reset()

func (*ListResiliencyResponse) String added in v1.7.0 

func (x *ListResiliencyResponse) String() string

type ListSubscriptionsRequest added in v1.7.0 

type ListSubscriptionsRequest struct {
	PodName   string `protobuf:"bytes,1,opt,name=podName,proto3" json:"podName,omitempty"`
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSubscriptionsRequest) Descriptor deprecated added in v1.7.0 

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

Deprecated: Use ListSubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsRequest) GetNamespace added in v1.7.0 

func (x *ListSubscriptionsRequest) GetNamespace() string

func (*ListSubscriptionsRequest) GetPodName added in v1.7.0 

func (x *ListSubscriptionsRequest) GetPodName() string

func (*ListSubscriptionsRequest) ProtoMessage added in v1.7.0 

func (*ListSubscriptionsRequest) ProtoMessage()

func (*ListSubscriptionsRequest) ProtoReflect added in v1.7.0 

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

func (*ListSubscriptionsRequest) Reset added in v1.7.0 

func (x *ListSubscriptionsRequest) Reset()

func (*ListSubscriptionsRequest) String added in v1.7.0 

func (x *ListSubscriptionsRequest) 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 *ComponentUpdateRequest, opts ...grpc.CallOption) (Operator_ComponentUpdateClient, error)
	// Returns a list of available components
	ListComponents(ctx context.Context, in *ListComponentsRequest, 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)
	// Returns a given resiliency configuration by name
	GetResiliency(ctx context.Context, in *GetResiliencyRequest, opts ...grpc.CallOption) (*GetResiliencyResponse, error)
	// Returns a list of resiliency configurations
	ListResiliency(ctx context.Context, in *ListResiliencyRequest, opts ...grpc.CallOption) (*ListResiliencyResponse, error)
	// Returns a list of pub/sub subscriptions, ListSubscriptionsRequest to expose pod info
	ListSubscriptionsV2(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)
	// Returns a list of http endpoints
	ListHTTPEndpoints(ctx context.Context, in *ListHTTPEndpointsRequest, opts ...grpc.CallOption) (*ListHTTPEndpointsResponse, error)
	// Sends events to Dapr sidecars upon http endpoint changes.
	HTTPEndpointUpdate(ctx context.Context, in *HTTPEndpointUpdateRequest, opts ...grpc.CallOption) (Operator_HTTPEndpointUpdateClient, 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(*ComponentUpdateRequest, Operator_ComponentUpdateServer) error
	// Returns a list of available components
	ListComponents(context.Context, *ListComponentsRequest) (*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)
	// Returns a given resiliency configuration by name
	GetResiliency(context.Context, *GetResiliencyRequest) (*GetResiliencyResponse, error)
	// Returns a list of resiliency configurations
	ListResiliency(context.Context, *ListResiliencyRequest) (*ListResiliencyResponse, error)
	// Returns a list of pub/sub subscriptions, ListSubscriptionsRequest to expose pod info
	ListSubscriptionsV2(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
	// Returns a list of http endpoints
	ListHTTPEndpoints(context.Context, *ListHTTPEndpointsRequest) (*ListHTTPEndpointsResponse, error)
	// Sends events to Dapr sidecars upon http endpoint changes.
	HTTPEndpointUpdate(*HTTPEndpointUpdateRequest, Operator_HTTPEndpointUpdateServer) 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 Operator_HTTPEndpointUpdateClient added in v1.11.0 

type Operator_HTTPEndpointUpdateClient interface {
	Recv() (*HTTPEndpointUpdateEvent, error)
	grpc.ClientStream
}

type Operator_HTTPEndpointUpdateServer added in v1.11.0 

type Operator_HTTPEndpointUpdateServer interface {
	Send(*HTTPEndpointUpdateEvent) error
	grpc.ServerStream
}

type ResourceEventType added in v1.13.0 

type ResourceEventType int32

ResourceEventType is the type of event to a resource. 

const (
	// UNKNOWN indicates that the event type is unknown.
	ResourceEventType_UNKNOWN ResourceEventType = 0
	// CREATED indicates that the resource has been created.
	ResourceEventType_CREATED ResourceEventType = 1
	// UPDATED indicates that the resource has been updated.
	ResourceEventType_UPDATED ResourceEventType = 2
	// DELETED indicates that the resource has been deleted.
	ResourceEventType_DELETED ResourceEventType = 3
)

func (ResourceEventType) Descriptor added in v1.13.0 

func (ResourceEventType) Descriptor() protoreflect.EnumDescriptor

func (ResourceEventType) Enum added in v1.13.0 

func (x ResourceEventType) Enum() *ResourceEventType

func (ResourceEventType) EnumDescriptor deprecated added in v1.13.0 

func (ResourceEventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ResourceEventType.Descriptor instead.

func (ResourceEventType) Number added in v1.13.0 

func (x ResourceEventType) Number() protoreflect.EnumNumber

func (ResourceEventType) String added in v1.13.0 

func (x ResourceEventType) String() string

func (ResourceEventType) Type added in v1.13.0 

func (ResourceEventType) Type() protoreflect.EnumType

type UnimplementedOperatorServer 

type UnimplementedOperatorServer struct {
}

UnimplementedOperatorServer should be embedded to have forward compatible implementations.

func (UnimplementedOperatorServer) ComponentUpdate 

func (UnimplementedOperatorServer) ComponentUpdate(*ComponentUpdateRequest, Operator_ComponentUpdateServer) error

func (UnimplementedOperatorServer) GetConfiguration 

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

func (UnimplementedOperatorServer) GetResiliency added in v1.7.0 

func (UnimplementedOperatorServer) GetResiliency(context.Context, *GetResiliencyRequest) (*GetResiliencyResponse, error)

func (UnimplementedOperatorServer) HTTPEndpointUpdate added in v1.11.0 

func (UnimplementedOperatorServer) HTTPEndpointUpdate(*HTTPEndpointUpdateRequest, Operator_HTTPEndpointUpdateServer) error

func (UnimplementedOperatorServer) ListComponents added in v0.8.0 

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

func (UnimplementedOperatorServer) ListHTTPEndpoints added in v1.11.0 

func (UnimplementedOperatorServer) ListHTTPEndpoints(context.Context, *ListHTTPEndpointsRequest) (*ListHTTPEndpointsResponse, error)

func (UnimplementedOperatorServer) ListResiliency added in v1.7.0 

func (UnimplementedOperatorServer) ListResiliency(context.Context, *ListResiliencyRequest) (*ListResiliencyResponse, error)

func (UnimplementedOperatorServer) ListSubscriptions added in v0.11.0 

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

func (UnimplementedOperatorServer) ListSubscriptionsV2 added in v1.7.0 

func (UnimplementedOperatorServer) ListSubscriptionsV2(context.Context, *ListSubscriptionsRequest) (*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.