topic

Documentation

Index

• func New(provider resource.GcpResourceResolver) (topicpb.TopicsServer, error)
• func NewWithClient(provider resource.GcpResourceResolver, client ifaces_pubsub.PubsubClient, ...) (topicpb.TopicsServer, error)
• type PubsubEventService
  • func (s *PubsubEventService) Publish(ctx context.Context, req *topicpb.TopicPublishRequest) (*topicpb.TopicPublishResponse, error)

Functions

func New

func New(provider resource.GcpResourceResolver) (topicpb.TopicsServer, error)

func NewWithClient

func NewWithClient(provider resource.GcpResourceResolver, client ifaces_pubsub.PubsubClient, tasksClient ifaces_cloudtasks.CloudtasksClient) (topicpb.TopicsServer, error)

Types

type PubsubEventService

type PubsubEventService struct {
	resource.GcpResourceResolver
	// contains filtered or unexported fields
}

func (*PubsubEventService) Publish

func (s *PubsubEventService) Publish(ctx context.Context, req *topicpb.TopicPublishRequest) (*topicpb.TopicPublishResponse, error)