dapr

type ListTopicSubscriptionsResponse struct {

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

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

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

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

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

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
}

type UnimplementedSubscribeServer struct {
}

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