publisher_v1

Documentation

Index

• type PublisherServer
  • func NewPublisherServer(grpcServer *grpc.Server) *PublisherServer
  • func (s *PublisherServer) ClearAllResponses(tid string)
  • func (s *PublisherServer) SetCreateTopicResponse(tid string, res *v1.Topic, err error)
  • func (s *PublisherServer) SetCreateTopicResponseCreator(tid string, ...)
  • func (s *PublisherServer) SetDeleteTopicResponse(tid string, res *emptypb.Empty, err error)
  • func (s *PublisherServer) SetDeleteTopicResponseCreator(tid string, ...)
  • func (s *PublisherServer) SetDetachSubscriptionResponse(tid string, res *v1.DetachSubscriptionResponse, err error)
  • func (s *PublisherServer) SetDetachSubscriptionResponseCreator(tid string, ...)
  • func (s *PublisherServer) SetGetTopicResponse(tid string, res *v1.Topic, err error)
  • func (s *PublisherServer) SetGetTopicResponseCreator(tid string, ...)
  • func (s *PublisherServer) SetListTopicSnapshotsResponse(tid string, res *v1.ListTopicSnapshotsResponse, err error)
  • func (s *PublisherServer) SetListTopicSnapshotsResponseCreator(tid string, ...)
  • func (s *PublisherServer) SetListTopicSubscriptionsResponse(tid string, res *v1.ListTopicSubscriptionsResponse, err error)
  • func (s *PublisherServer) SetListTopicSubscriptionsResponseCreator(tid string, ...)
  • func (s *PublisherServer) SetListTopicsResponse(tid string, res *v1.ListTopicsResponse, err error)
  • func (s *PublisherServer) SetListTopicsResponseCreator(tid string, ...)
  • func (s *PublisherServer) SetPublishResponse(tid string, res *v1.PublishResponse, err error)
  • func (s *PublisherServer) SetPublishResponseCreator(tid string, ...)
  • func (s *PublisherServer) SetUpdateTopicResponse(tid string, res *v1.Topic, err error)
  • func (s *PublisherServer) SetUpdateTopicResponseCreator(tid string, ...)

Types

type PublisherServer

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

func NewPublisherServer

func NewPublisherServer(
	grpcServer *grpc.Server,
) *PublisherServer

func (*PublisherServer) ClearAllResponses

func (s *PublisherServer) ClearAllResponses(
	tid string,
)

func (*PublisherServer) SetCreateTopicResponse

func (s *PublisherServer) SetCreateTopicResponse(
	tid string,
	res *v1.Topic,
	err error,
)

func (*PublisherServer) SetCreateTopicResponseCreator

func (s *PublisherServer) SetCreateTopicResponseCreator(
	tid string,
	creator func(ctx context.Context, req *v1.Topic) (*v1.Topic, error))

func (*PublisherServer) SetDeleteTopicResponse

func (s *PublisherServer) SetDeleteTopicResponse(
	tid string,
	res *emptypb.Empty,
	err error,
)

func (*PublisherServer) SetDeleteTopicResponseCreator

func (s *PublisherServer) SetDeleteTopicResponseCreator(
	tid string,
	creator func(ctx context.Context, req *v1.DeleteTopicRequest) (*emptypb.Empty, error))

func (*PublisherServer) SetDetachSubscriptionResponse

func (s *PublisherServer) SetDetachSubscriptionResponse(
	tid string,
	res *v1.DetachSubscriptionResponse,
	err error,
)

func (*PublisherServer) SetDetachSubscriptionResponseCreator

func (s *PublisherServer) SetDetachSubscriptionResponseCreator(
	tid string,
	creator func(ctx context.Context, req *v1.DetachSubscriptionRequest) (*v1.DetachSubscriptionResponse, error))

func (*PublisherServer) SetGetTopicResponse

func (s *PublisherServer) SetGetTopicResponse(
	tid string,
	res *v1.Topic,
	err error,
)

func (*PublisherServer) SetGetTopicResponseCreator

func (s *PublisherServer) SetGetTopicResponseCreator(
	tid string,
	creator func(ctx context.Context, req *v1.GetTopicRequest) (*v1.Topic, error))

func (*PublisherServer) SetListTopicSnapshotsResponse

func (s *PublisherServer) SetListTopicSnapshotsResponse(
	tid string,
	res *v1.ListTopicSnapshotsResponse,
	err error,
)

func (*PublisherServer) SetListTopicSnapshotsResponseCreator

func (s *PublisherServer) SetListTopicSnapshotsResponseCreator(
	tid string,
	creator func(ctx context.Context, req *v1.ListTopicSnapshotsRequest) (*v1.ListTopicSnapshotsResponse, error))

func (*PublisherServer) SetListTopicSubscriptionsResponse

func (s *PublisherServer) SetListTopicSubscriptionsResponse(
	tid string,
	res *v1.ListTopicSubscriptionsResponse,
	err error,
)

func (*PublisherServer) SetListTopicSubscriptionsResponseCreator

func (s *PublisherServer) SetListTopicSubscriptionsResponseCreator(
	tid string,
	creator func(ctx context.Context, req *v1.ListTopicSubscriptionsRequest) (*v1.ListTopicSubscriptionsResponse, error))

func (*PublisherServer) SetListTopicsResponse

func (s *PublisherServer) SetListTopicsResponse(
	tid string,
	res *v1.ListTopicsResponse,
	err error,
)

func (*PublisherServer) SetListTopicsResponseCreator

func (s *PublisherServer) SetListTopicsResponseCreator(
	tid string,
	creator func(ctx context.Context, req *v1.ListTopicsRequest) (*v1.ListTopicsResponse, error))

func (*PublisherServer) SetPublishResponse

func (s *PublisherServer) SetPublishResponse(
	tid string,
	res *v1.PublishResponse,
	err error,
)

func (*PublisherServer) SetPublishResponseCreator

func (s *PublisherServer) SetPublishResponseCreator(
	tid string,
	creator func(ctx context.Context, req *v1.PublishRequest) (*v1.PublishResponse, error))

func (*PublisherServer) SetUpdateTopicResponse

func (s *PublisherServer) SetUpdateTopicResponse(
	tid string,
	res *v1.Topic,
	err error,
)

func (*PublisherServer) SetUpdateTopicResponseCreator

func (s *PublisherServer) SetUpdateTopicResponseCreator(
	tid string,
	creator func(ctx context.Context, req *v1.UpdateTopicRequest) (*v1.Topic, error))