dapr

Documentation

Index

• Variables
• func RegisterSubscribeHTTPServer(container *go_restful.Container, srv SubscribeHTTPServer)
• func RegisterSubscribeServer(s grpc.ServiceRegistrar, srv SubscribeServer)
• type ListTopicSubscriptionsResponse
  • func (*ListTopicSubscriptionsResponse) Descriptor() ([]byte, []int)
  • func (x *ListTopicSubscriptionsResponse) GetSubscriptions() []*TopicSubscription
  • func (*ListTopicSubscriptionsResponse) ProtoMessage()
  • func (x *ListTopicSubscriptionsResponse) ProtoReflect() protoreflect.Message
  • func (x *ListTopicSubscriptionsResponse) Reset()
  • func (x *ListTopicSubscriptionsResponse) String() string
• type SubscribeClient
  • func NewSubscribeClient(cc grpc.ClientConnInterface) SubscribeClient
• type SubscribeHTTPHandler
  • func (h *SubscribeHTTPHandler) GetSubscribe(req *go_restful.Request, resp *go_restful.Response)
• type SubscribeHTTPServer
• type SubscribeServer
• type TopicSubscription
  • func (*TopicSubscription) Descriptor() ([]byte, []int)
  • func (x *TopicSubscription) GetMetadata() map[string]string
  • func (x *TopicSubscription) GetPubsubname() string
  • func (x *TopicSubscription) GetRoute() string
  • func (x *TopicSubscription) GetTopic() string
  • func (*TopicSubscription) ProtoMessage()
  • func (x *TopicSubscription) ProtoReflect() protoreflect.Message
  • func (x *TopicSubscription) Reset()
  • func (x *TopicSubscription) String() string
• type UnimplementedSubscribeServer
  • func (UnimplementedSubscribeServer) GetSubscribe(context.Context, *emptypb.Empty) (*ListTopicSubscriptionsResponse, error)
• type UnsafeSubscribeServer

Variables

var File_api_dapr_subscribe_proto protoreflect.FileDescriptor

var Subscribe_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.dapr.Subscribe",
	HandlerType: (*SubscribeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSubscribe",
			Handler:    _Subscribe_GetSubscribe_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/dapr/subscribe.proto",
}

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

Functions

func RegisterSubscribeHTTPServer

func RegisterSubscribeHTTPServer(container *go_restful.Container, srv SubscribeHTTPServer)

func RegisterSubscribeServer

func RegisterSubscribeServer(s grpc.ServiceRegistrar, srv SubscribeServer)

Types

type ListTopicSubscriptionsResponse

type ListTopicSubscriptionsResponse struct {

	// The list of topics.
	Subscriptions []*TopicSubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

ListTopicSubscriptionsResponse is the message including the list of the subscribing topics.

func (*ListTopicSubscriptionsResponse) Descriptor

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

Deprecated: Use ListTopicSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicSubscriptionsResponse) GetSubscriptions

func (x *ListTopicSubscriptionsResponse) GetSubscriptions() []*TopicSubscription

func (*ListTopicSubscriptionsResponse) ProtoMessage

func (*ListTopicSubscriptionsResponse) ProtoMessage()

func (*ListTopicSubscriptionsResponse) ProtoReflect

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

func (*ListTopicSubscriptionsResponse) Reset

func (x *ListTopicSubscriptionsResponse) Reset()

func (*ListTopicSubscriptionsResponse) String

func (x *ListTopicSubscriptionsResponse) String() string

type SubscribeClient

type SubscribeClient interface {
	GetSubscribe(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error)
}

SubscribeClient is the client API for Subscribe 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 NewSubscribeClient

func NewSubscribeClient(cc grpc.ClientConnInterface) SubscribeClient

type SubscribeHTTPHandler

type SubscribeHTTPHandler struct {
	// contains filtered or unexported fields
}

func (*SubscribeHTTPHandler) GetSubscribe

func (h *SubscribeHTTPHandler) GetSubscribe(req *go_restful.Request, resp *go_restful.Response)

type SubscribeHTTPServer

type SubscribeHTTPServer interface {
	GetSubscribe(context.Context, *emptypb.Empty) (*ListTopicSubscriptionsResponse, error)
}

type SubscribeServer

type SubscribeServer interface {
	GetSubscribe(context.Context, *emptypb.Empty) (*ListTopicSubscriptionsResponse, error)
	// contains filtered or unexported methods
}

SubscribeServer is the server API for Subscribe service. All implementations must embed UnimplementedSubscribeServer for forward compatibility

type TopicSubscription

type TopicSubscription struct {

	// Required. The name of the pubsub containing the topic below to subscribe to.
	Pubsubname string `protobuf:"bytes,1,opt,name=pubsubname,proto3" json:"pubsubname,omitempty"`
	// Required. The name of topic which will be subscribed
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// The optional properties used for this topic's subscription e.g. session id
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The optional routing rules to match against. In the gRPC interface, OnTopicEvent
	// is still invoked but the matching path is sent in the TopicEventRequest.
	Route string `protobuf:"bytes,5,opt,name=route,proto3" json:"route,omitempty"`
	// contains filtered or unexported fields
}

TopicSubscription represents topic and metadata.

func (*TopicSubscription) Descriptor

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

Deprecated: Use TopicSubscription.ProtoReflect.Descriptor instead.

func (*TopicSubscription) GetMetadata

func (x *TopicSubscription) GetMetadata() map[string]string

func (*TopicSubscription) GetPubsubname

func (x *TopicSubscription) GetPubsubname() string

func (*TopicSubscription) GetRoute

func (x *TopicSubscription) GetRoute() string

func (*TopicSubscription) GetTopic

func (x *TopicSubscription) GetTopic() string

func (*TopicSubscription) ProtoMessage

func (*TopicSubscription) ProtoMessage()

func (*TopicSubscription) ProtoReflect

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

func (*TopicSubscription) Reset

func (x *TopicSubscription) Reset()

func (*TopicSubscription) String

func (x *TopicSubscription) String() string

type UnimplementedSubscribeServer

type UnimplementedSubscribeServer struct {
}

UnimplementedSubscribeServer must be embedded to have forward compatible implementations.

func (UnimplementedSubscribeServer) GetSubscribe

func (UnimplementedSubscribeServer) GetSubscribe(context.Context, *emptypb.Empty) (*ListTopicSubscriptionsResponse, error)

type UnsafeSubscribeServer

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

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