operator

package
v0.0.0-...-949823d Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Operator_ComponentUpdate_FullMethodName     = "/dapr.proto.operator.v1.Operator/ComponentUpdate"
	Operator_ListComponents_FullMethodName      = "/dapr.proto.operator.v1.Operator/ListComponents"
	Operator_GetConfiguration_FullMethodName    = "/dapr.proto.operator.v1.Operator/GetConfiguration"
	Operator_ListSubscriptions_FullMethodName   = "/dapr.proto.operator.v1.Operator/ListSubscriptions"
	Operator_GetResiliency_FullMethodName       = "/dapr.proto.operator.v1.Operator/GetResiliency"
	Operator_ListResiliency_FullMethodName      = "/dapr.proto.operator.v1.Operator/ListResiliency"
	Operator_ListSubscriptionsV2_FullMethodName = "/dapr.proto.operator.v1.Operator/ListSubscriptionsV2"
	Operator_SubscriptionUpdate_FullMethodName  = "/dapr.proto.operator.v1.Operator/SubscriptionUpdate"
	Operator_ListHTTPEndpoints_FullMethodName   = "/dapr.proto.operator.v1.Operator/ListHTTPEndpoints"
	Operator_HTTPEndpointUpdate_FullMethodName  = "/dapr.proto.operator.v1.Operator/HTTPEndpointUpdate"
)

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 (
	ResourceConditionStatus_name = map[int32]string{
		0: "STATUS_UNKNOWN",
		1: "STATUS_SUCCESS",
		2: "STATUS_FAILURE",
	}
	ResourceConditionStatus_value = map[string]int32{
		"STATUS_UNKNOWN": 0,
		"STATUS_SUCCESS": 1,
		"STATUS_FAILURE": 2,
	}
)

Enum value maps for ResourceConditionStatus.

View Source 
var (
	ResourceType_name = map[int32]string{
		0: "RESOURCE_UNKNOWN",
		1: "RESOURCE_COMPONENT",
	}
	ResourceType_value = map[string]int32{
		"RESOURCE_UNKNOWN":   0,
		"RESOURCE_COMPONENT": 1,
	}
)

Enum value maps for ResourceType.

View Source 
var (
	EventType_name = map[int32]string{
		0: "EVENT_UNKNOWN",
		1: "EVENT_INIT",
		2: "EVENT_CLOSE",
	}
	EventType_value = map[string]int32{
		"EVENT_UNKNOWN": 0,
		"EVENT_INIT":    1,
		"EVENT_CLOSE":   2,
	}
)

Enum value maps for EventType.

View Source 
var File_dapr_proto_operator_v1_operator_proto protoreflect.FileDescriptor
View Source 
var File_dapr_proto_operator_v1_resource_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:    "SubscriptionUpdate",
			Handler:       _Operator_SubscriptionUpdate_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 

func (x *ComponentUpdateEvent) GetType() ResourceEventType

func (*ComponentUpdateEvent) ProtoMessage 

func (*ComponentUpdateEvent) ProtoMessage()

func (*ComponentUpdateEvent) ProtoReflect 

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

func (*ComponentUpdateEvent) Reset 

func (x *ComponentUpdateEvent) Reset()

func (*ComponentUpdateEvent) String 

func (x *ComponentUpdateEvent) String() string

type ComponentUpdateRequest 

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 

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

Deprecated: Use ComponentUpdateRequest.ProtoReflect.Descriptor instead.

func (*ComponentUpdateRequest) GetNamespace 

func (x *ComponentUpdateRequest) GetNamespace() string

func (*ComponentUpdateRequest) GetPodName 

func (x *ComponentUpdateRequest) GetPodName() string

func (*ComponentUpdateRequest) ProtoMessage 

func (*ComponentUpdateRequest) ProtoMessage()

func (*ComponentUpdateRequest) ProtoReflect 

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

func (*ComponentUpdateRequest) Reset 

func (x *ComponentUpdateRequest) Reset()

func (*ComponentUpdateRequest) String 

func (x *ComponentUpdateRequest) String() string

type EventType 

type EventType int32

EventType is the type of the event. 

const (
	// UNKNOWN indicates that the event type is unknown.
	EventType_EVENT_UNKNOWN EventType = 0
	// EVENT_INIT indicates that the event type is init.
	EventType_EVENT_INIT EventType = 1
	// EVENT_CLOSE indicates that the event type is close.
	EventType_EVENT_CLOSE EventType = 2
)

func (EventType) Descriptor 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated 

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

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String 

func (x EventType) String() string

func (EventType) Type 

func (EventType) Type() protoreflect.EnumType

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 

func (x *GetConfigurationRequest) GetPodName() string

func (*GetConfigurationRequest) ProtoMessage 

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) ProtoReflect 

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 

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

func (*GetConfigurationResponse) Reset 

func (x *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) String 

func (x *GetConfigurationResponse) String() string

type GetHTTPEndpointRequest 

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 

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

Deprecated: Use GetHTTPEndpointRequest.ProtoReflect.Descriptor instead.

func (*GetHTTPEndpointRequest) GetName 

func (x *GetHTTPEndpointRequest) GetName() string

func (*GetHTTPEndpointRequest) GetNamespace 

func (x *GetHTTPEndpointRequest) GetNamespace() string

func (*GetHTTPEndpointRequest) ProtoMessage 

func (*GetHTTPEndpointRequest) ProtoMessage()

func (*GetHTTPEndpointRequest) ProtoReflect 

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

func (*GetHTTPEndpointRequest) Reset 

func (x *GetHTTPEndpointRequest) Reset()

func (*GetHTTPEndpointRequest) String 

func (x *GetHTTPEndpointRequest) String() string

type GetHTTPEndpointResponse 

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 

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

Deprecated: Use GetHTTPEndpointResponse.ProtoReflect.Descriptor instead.

func (*GetHTTPEndpointResponse) GetHttpEndpoint 

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

func (*GetHTTPEndpointResponse) ProtoMessage 

func (*GetHTTPEndpointResponse) ProtoMessage()

func (*GetHTTPEndpointResponse) ProtoReflect 

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

func (*GetHTTPEndpointResponse) Reset 

func (x *GetHTTPEndpointResponse) Reset()

func (*GetHTTPEndpointResponse) String 

func (x *GetHTTPEndpointResponse) String() string

type GetResiliencyRequest 

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 

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

Deprecated: Use GetResiliencyRequest.ProtoReflect.Descriptor instead.

func (*GetResiliencyRequest) GetName 

func (x *GetResiliencyRequest) GetName() string

func (*GetResiliencyRequest) GetNamespace 

func (x *GetResiliencyRequest) GetNamespace() string

func (*GetResiliencyRequest) ProtoMessage 

func (*GetResiliencyRequest) ProtoMessage()

func (*GetResiliencyRequest) ProtoReflect 

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

func (*GetResiliencyRequest) Reset 

func (x *GetResiliencyRequest) Reset()

func (*GetResiliencyRequest) String 

func (x *GetResiliencyRequest) String() string

type GetResiliencyResponse 

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 

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

Deprecated: Use GetResiliencyResponse.ProtoReflect.Descriptor instead.

func (*GetResiliencyResponse) GetResiliency 

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

func (*GetResiliencyResponse) ProtoMessage 

func (*GetResiliencyResponse) ProtoMessage()

func (*GetResiliencyResponse) ProtoReflect 

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

func (*GetResiliencyResponse) Reset 

func (x *GetResiliencyResponse) Reset()

func (*GetResiliencyResponse) String 

func (x *GetResiliencyResponse) String() string

type HTTPEndpointUpdateEvent 

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 

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

Deprecated: Use HTTPEndpointUpdateEvent.ProtoReflect.Descriptor instead.

func (*HTTPEndpointUpdateEvent) GetHttpEndpoints 

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

func (*HTTPEndpointUpdateEvent) ProtoMessage 

func (*HTTPEndpointUpdateEvent) ProtoMessage()

func (*HTTPEndpointUpdateEvent) ProtoReflect 

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

func (*HTTPEndpointUpdateEvent) Reset 

func (x *HTTPEndpointUpdateEvent) Reset()

func (*HTTPEndpointUpdateEvent) String 

func (x *HTTPEndpointUpdateEvent) String() string

type HTTPEndpointUpdateRequest 

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 

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

Deprecated: Use HTTPEndpointUpdateRequest.ProtoReflect.Descriptor instead.

func (*HTTPEndpointUpdateRequest) GetNamespace 

func (x *HTTPEndpointUpdateRequest) GetNamespace() string

func (*HTTPEndpointUpdateRequest) GetPodName 

func (x *HTTPEndpointUpdateRequest) GetPodName() string

func (*HTTPEndpointUpdateRequest) ProtoMessage 

func (*HTTPEndpointUpdateRequest) ProtoMessage()

func (*HTTPEndpointUpdateRequest) ProtoReflect 

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

func (*HTTPEndpointUpdateRequest) Reset 

func (x *HTTPEndpointUpdateRequest) Reset()

func (*HTTPEndpointUpdateRequest) String 

func (x *HTTPEndpointUpdateRequest) String() string

type ListComponentResponse 

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 

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

Deprecated: Use ListComponentResponse.ProtoReflect.Descriptor instead.

func (*ListComponentResponse) GetComponents 

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

func (*ListComponentResponse) ProtoMessage 

func (*ListComponentResponse) ProtoMessage()

func (*ListComponentResponse) ProtoReflect 

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

func (*ListComponentResponse) Reset 

func (x *ListComponentResponse) Reset()

func (*ListComponentResponse) String 

func (x *ListComponentResponse) String() string

type ListComponentsRequest 

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 

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

Deprecated: Use ListComponentsRequest.ProtoReflect.Descriptor instead.

func (*ListComponentsRequest) GetNamespace 

func (x *ListComponentsRequest) GetNamespace() string

func (*ListComponentsRequest) GetPodName 

func (x *ListComponentsRequest) GetPodName() string

func (*ListComponentsRequest) ProtoMessage 

func (*ListComponentsRequest) ProtoMessage()

func (*ListComponentsRequest) ProtoReflect 

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

func (*ListComponentsRequest) Reset 

func (x *ListComponentsRequest) Reset()

func (*ListComponentsRequest) String 

func (x *ListComponentsRequest) String() string

type ListHTTPEndpointsRequest 

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

func (*ListHTTPEndpointsRequest) Descriptor deprecated 

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

Deprecated: Use ListHTTPEndpointsRequest.ProtoReflect.Descriptor instead.

func (*ListHTTPEndpointsRequest) GetNamespace 

func (x *ListHTTPEndpointsRequest) GetNamespace() string

func (*ListHTTPEndpointsRequest) ProtoMessage 

func (*ListHTTPEndpointsRequest) ProtoMessage()

func (*ListHTTPEndpointsRequest) ProtoReflect 

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

func (*ListHTTPEndpointsRequest) Reset 

func (x *ListHTTPEndpointsRequest) Reset()

func (*ListHTTPEndpointsRequest) String 

func (x *ListHTTPEndpointsRequest) String() string

type ListHTTPEndpointsResponse 

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 

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

Deprecated: Use ListHTTPEndpointsResponse.ProtoReflect.Descriptor instead.

func (*ListHTTPEndpointsResponse) GetHttpEndpoints 

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

func (*ListHTTPEndpointsResponse) ProtoMessage 

func (*ListHTTPEndpointsResponse) ProtoMessage()

func (*ListHTTPEndpointsResponse) ProtoReflect 

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

func (*ListHTTPEndpointsResponse) Reset 

func (x *ListHTTPEndpointsResponse) Reset()

func (*ListHTTPEndpointsResponse) String 

func (x *ListHTTPEndpointsResponse) String() string

type ListResiliencyRequest 

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 

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

Deprecated: Use ListResiliencyRequest.ProtoReflect.Descriptor instead.

func (*ListResiliencyRequest) GetNamespace 

func (x *ListResiliencyRequest) GetNamespace() string

func (*ListResiliencyRequest) ProtoMessage 

func (*ListResiliencyRequest) ProtoMessage()

func (*ListResiliencyRequest) ProtoReflect 

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

func (*ListResiliencyRequest) Reset 

func (x *ListResiliencyRequest) Reset()

func (*ListResiliencyRequest) String 

func (x *ListResiliencyRequest) String() string

type ListResiliencyResponse 

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 

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

Deprecated: Use ListResiliencyResponse.ProtoReflect.Descriptor instead.

func (*ListResiliencyResponse) GetResiliencies 

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

func (*ListResiliencyResponse) ProtoMessage 

func (*ListResiliencyResponse) ProtoMessage()

func (*ListResiliencyResponse) ProtoReflect 

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

func (*ListResiliencyResponse) Reset 

func (x *ListResiliencyResponse) Reset()

func (*ListResiliencyResponse) String 

func (x *ListResiliencyResponse) String() string

type ListSubscriptionsRequest 

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 

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

Deprecated: Use ListSubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsRequest) GetNamespace 

func (x *ListSubscriptionsRequest) GetNamespace() string

func (*ListSubscriptionsRequest) GetPodName 

func (x *ListSubscriptionsRequest) GetPodName() string

func (*ListSubscriptionsRequest) ProtoMessage 

func (*ListSubscriptionsRequest) ProtoMessage()

func (*ListSubscriptionsRequest) ProtoReflect 

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

func (*ListSubscriptionsRequest) Reset 

func (x *ListSubscriptionsRequest) Reset()

func (*ListSubscriptionsRequest) String 

func (x *ListSubscriptionsRequest) String() string

type ListSubscriptionsResponse 

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 

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

Deprecated: Use ListSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsResponse) GetSubscriptions 

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

func (*ListSubscriptionsResponse) ProtoMessage 

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) ProtoReflect 

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

func (*ListSubscriptionsResponse) Reset 

func (x *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) String 

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)
	// Sends events to Dapr sidecars upon subscription changes.
	SubscriptionUpdate(ctx context.Context, in *SubscriptionUpdateRequest, opts ...grpc.CallOption) (Operator_SubscriptionUpdateClient, 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)
	// Sends events to Dapr sidecars upon subscription changes.
	SubscriptionUpdate(*SubscriptionUpdateRequest, Operator_SubscriptionUpdateServer) 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 

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

type Operator_HTTPEndpointUpdateServer 

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

type Operator_SubscriptionUpdateClient 

type Operator_SubscriptionUpdateClient interface {
	Recv() (*SubscriptionUpdateEvent, error)
	grpc.ClientStream
}

type Operator_SubscriptionUpdateServer 

type Operator_SubscriptionUpdateServer interface {
	Send(*SubscriptionUpdateEvent) error
	grpc.ServerStream
}

type ResourceConditionStatus 

type ResourceConditionStatus int32

ResourceConditionStatus is the status condition to a resource. 

const (
	// STATUS_UNKNOWN indicates that the condition status is unknown.
	ResourceConditionStatus_STATUS_UNKNOWN ResourceConditionStatus = 0
	// STATUS_SUCCESS indicates that the condition status is success.
	ResourceConditionStatus_STATUS_SUCCESS ResourceConditionStatus = 1
	// STATUS_FAILURE indicates that the condition status is failed.
	ResourceConditionStatus_STATUS_FAILURE ResourceConditionStatus = 2
)

func (ResourceConditionStatus) Descriptor 

func (ResourceConditionStatus) Descriptor() protoreflect.EnumDescriptor

func (ResourceConditionStatus) Enum 

func (x ResourceConditionStatus) Enum() *ResourceConditionStatus

func (ResourceConditionStatus) EnumDescriptor deprecated 

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

Deprecated: Use ResourceConditionStatus.Descriptor instead.

func (ResourceConditionStatus) Number 

func (x ResourceConditionStatus) Number() protoreflect.EnumNumber

func (ResourceConditionStatus) String 

func (x ResourceConditionStatus) String() string

func (ResourceConditionStatus) Type 

func (ResourceConditionStatus) Type() protoreflect.EnumType

type ResourceEventType 

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 

func (ResourceEventType) Descriptor() protoreflect.EnumDescriptor

func (ResourceEventType) Enum 

func (x ResourceEventType) Enum() *ResourceEventType

func (ResourceEventType) EnumDescriptor deprecated 

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

Deprecated: Use ResourceEventType.Descriptor instead.

func (ResourceEventType) Number 

func (x ResourceEventType) Number() protoreflect.EnumNumber

func (ResourceEventType) String 

func (x ResourceEventType) String() string

func (ResourceEventType) Type 

func (ResourceEventType) Type() protoreflect.EnumType

type ResourceResult 

type ResourceResult struct {

	// resource_type is the type of the resource.
	ResourceType ResourceType `` /* 139-byte string literal not displayed */
	// event_type is the type of the event.
	EventType EventType `` /* 127-byte string literal not displayed */
	// name is the name of the resource.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// condition is the condition of the resource.
	Condition ResourceConditionStatus `protobuf:"varint,4,opt,name=condition,proto3,enum=dapr.proto.operator.v1.ResourceConditionStatus" json:"condition,omitempty"`
	// Reason is a brief machine readable explanation for the condition's last
	// transition.
	Reason *string `protobuf:"bytes,5,opt,name=reason,proto3,oneof" json:"reason,omitempty"`
	// Message is a human readable description of the details of the last
	// transition, complementing reason.
	Message *string `protobuf:"bytes,6,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// observed_generation is the generation of the resource. Represents the
	// .metadata.generation that the condition was set based upon. For instance,
	// if .metadata.generation is currently 12, but the
	// .status.condition[x].observedGeneration is 9, the condition is out of date
	// with respect to the current state of the Component.
	ObservedGeneration int64 `protobuf:"varint,7,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"`
	// last_transaction_time is the timestamp corresponding to the last status
	// change of this condition.
	LastTransactionTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=last_transaction_time,json=lastTransactionTime,proto3" json:"last_transaction_time,omitempty"`
	// contains filtered or unexported fields
}

ResourceResult is the result of the resource initialization.

func (*ResourceResult) Descriptor deprecated 

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

Deprecated: Use ResourceResult.ProtoReflect.Descriptor instead.

func (*ResourceResult) GetCondition 

func (x *ResourceResult) GetCondition() ResourceConditionStatus

func (*ResourceResult) GetEventType 

func (x *ResourceResult) GetEventType() EventType

func (*ResourceResult) GetLastTransactionTime 

func (x *ResourceResult) GetLastTransactionTime() *timestamppb.Timestamp

func (*ResourceResult) GetMessage 

func (x *ResourceResult) GetMessage() string

func (*ResourceResult) GetName 

func (x *ResourceResult) GetName() string

func (*ResourceResult) GetObservedGeneration 

func (x *ResourceResult) GetObservedGeneration() int64

func (*ResourceResult) GetReason 

func (x *ResourceResult) GetReason() string

func (*ResourceResult) GetResourceType 

func (x *ResourceResult) GetResourceType() ResourceType

func (*ResourceResult) ProtoMessage 

func (*ResourceResult) ProtoMessage()

func (*ResourceResult) ProtoReflect 

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

func (*ResourceResult) Reset 

func (x *ResourceResult) Reset()

func (*ResourceResult) String 

func (x *ResourceResult) String() string

type ResourceType 

type ResourceType int32

ResourceType is the type of the resource. 

const (
	// UNKNOWN_RESOURCE indicates that the resource type is unknown.
	ResourceType_RESOURCE_UNKNOWN ResourceType = 0
	// RESOURCE_COMPONENT indicates that the resource type is a component.
	ResourceType_RESOURCE_COMPONENT ResourceType = 1
)

func (ResourceType) Descriptor 

func (ResourceType) Descriptor() protoreflect.EnumDescriptor

func (ResourceType) Enum 

func (x ResourceType) Enum() *ResourceType

func (ResourceType) EnumDescriptor deprecated 

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

Deprecated: Use ResourceType.Descriptor instead.

func (ResourceType) Number 

func (x ResourceType) Number() protoreflect.EnumNumber

func (ResourceType) String 

func (x ResourceType) String() string

func (ResourceType) Type 

func (ResourceType) Type() protoreflect.EnumType

type SubscriptionUpdateEvent 

type SubscriptionUpdateEvent struct {
	Subscription []byte `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,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
}

SubscriptionUpdateEvent includes the updated subscription event.

func (*SubscriptionUpdateEvent) Descriptor deprecated 

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

Deprecated: Use SubscriptionUpdateEvent.ProtoReflect.Descriptor instead.

func (*SubscriptionUpdateEvent) GetSubscription 

func (x *SubscriptionUpdateEvent) GetSubscription() []byte

func (*SubscriptionUpdateEvent) GetType 

func (x *SubscriptionUpdateEvent) GetType() ResourceEventType

func (*SubscriptionUpdateEvent) ProtoMessage 

func (*SubscriptionUpdateEvent) ProtoMessage()

func (*SubscriptionUpdateEvent) ProtoReflect 

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

func (*SubscriptionUpdateEvent) Reset 

func (x *SubscriptionUpdateEvent) Reset()

func (*SubscriptionUpdateEvent) String 

func (x *SubscriptionUpdateEvent) String() string

type SubscriptionUpdateRequest 

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

SubscriptionUpdateRequest is the request to get updates about new subscriptions for a given namespace.

func (*SubscriptionUpdateRequest) Descriptor deprecated 

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

Deprecated: Use SubscriptionUpdateRequest.ProtoReflect.Descriptor instead.

func (*SubscriptionUpdateRequest) GetNamespace 

func (x *SubscriptionUpdateRequest) GetNamespace() string

func (*SubscriptionUpdateRequest) GetPodName 

func (x *SubscriptionUpdateRequest) GetPodName() string

func (*SubscriptionUpdateRequest) ProtoMessage 

func (*SubscriptionUpdateRequest) ProtoMessage()

func (*SubscriptionUpdateRequest) ProtoReflect 

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

func (*SubscriptionUpdateRequest) Reset 

func (x *SubscriptionUpdateRequest) Reset()

func (*SubscriptionUpdateRequest) String 

func (x *SubscriptionUpdateRequest) String() string

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 

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

func (UnimplementedOperatorServer) HTTPEndpointUpdate 

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

func (UnimplementedOperatorServer) ListComponents 

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

func (UnimplementedOperatorServer) ListHTTPEndpoints 

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

func (UnimplementedOperatorServer) ListResiliency 

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

func (UnimplementedOperatorServer) ListSubscriptions 

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

func (UnimplementedOperatorServer) ListSubscriptionsV2 

func (UnimplementedOperatorServer) ListSubscriptionsV2(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

func (UnimplementedOperatorServer) SubscriptionUpdate 

func (UnimplementedOperatorServer) SubscriptionUpdate(*SubscriptionUpdateRequest, Operator_SubscriptionUpdateServer) error

type UnsafeOperatorServer 

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.