topicspb

type ClientMessage struct {

	// globally unique ID of the request/response pair
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Content:
	//
	//	*ClientMessage_RegistrationRequest
	//	*ClientMessage_MessageResponse
	Content isClientMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

type ClientMessage_MessageResponse struct {
	// Handle a message received from a topic
	MessageResponse *MessageResponse `protobuf:"bytes,3,opt,name=message_response,json=messageResponse,proto3,oneof"`
}

type ClientMessage_RegistrationRequest struct {
	// Register a subscription to a topic
	RegistrationRequest *RegistrationRequest `protobuf:"bytes,2,opt,name=registration_request,json=registrationRequest,proto3,oneof"`
}

type MessageRequest struct {
	TopicName string `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// Message Type
	Message *TopicMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type MessageResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type RegistrationRequest struct {
	TopicName string `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// contains filtered or unexported fields
}

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

type ServerMessage struct {

	// globally unique ID of the request/response pair
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Content:
	//
	//	*ServerMessage_RegistrationResponse
	//	*ServerMessage_MessageRequest
	Content isServerMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

type ServerMessage_MessageRequest struct {
	// Response to a topic message request
	MessageRequest *MessageRequest `protobuf:"bytes,3,opt,name=message_request,json=messageRequest,proto3,oneof"`
}

type ServerMessage_RegistrationResponse struct {
	// Response to a topic subscription request
	RegistrationResponse *RegistrationResponse `protobuf:"bytes,2,opt,name=registration_response,json=registrationResponse,proto3,oneof"`
}

type SubscriberClient interface {
	// Subscribe to a topic and handle incoming messages
	Subscribe(ctx context.Context, opts ...grpc.CallOption) (Subscriber_SubscribeClient, error)
}

type SubscriberServer interface {
	// Subscribe to a topic and handle incoming messages
	Subscribe(Subscriber_SubscribeServer) error
}

type Subscriber_SubscribeClient interface {
	Send(*ClientMessage) error
	Recv() (*ServerMessage, error)
	grpc.ClientStream
}

type Subscriber_SubscribeServer interface {
	Send(*ServerMessage) error
	Recv() (*ClientMessage, error)
	grpc.ServerStream
}

type TopicMessage struct {

	// The topic message contents
	//
	// Types that are assignable to Content:
	//
	//	*TopicMessage_StructPayload
	Content isTopicMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

type TopicMessage_StructPayload struct {
	StructPayload *structpb.Struct `protobuf:"bytes,1,opt,name=struct_payload,json=structPayload,proto3,oneof"`
}

type TopicPublishRequest struct {

	// The name of the topic to publish the topic to
	TopicName string `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// The message to be published
	Message *TopicMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// An optional delay specified in seconds (minimum 10 seconds)
	Delay *durationpb.Duration `protobuf:"bytes,3,opt,name=delay,proto3" json:"delay,omitempty"`
	// contains filtered or unexported fields
}

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

type TopicsClient interface {
	// Publishes a message to a given topic
	Publish(ctx context.Context, in *TopicPublishRequest, opts ...grpc.CallOption) (*TopicPublishResponse, error)
}

type TopicsServer interface {
	// Publishes a message to a given topic
	Publish(context.Context, *TopicPublishRequest) (*TopicPublishResponse, error)
}

type UnimplementedSubscriberServer struct {
}

type UnimplementedTopicsServer struct {
}

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

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