eventv1sdk

Documentation

Index

• Variables
• func NewEventServiceClient(uri string, options ...connect.ClientOption) eventv1.EventServiceClient
• func NewPubsubEventServiceClient(ctx context.Context, config *PubsubEventServiceClientConfig) (eventv1.EventServiceClient, error)
• type EventPubsubService
  • func (x *EventPubsubService) PushPubsubMessage(ctx context.Context, r *pubsubv1.PushPubsubMessageRequest) (*pubsubv1.PushPubsubMessageResponse, error)
• type EventService
  • func (x *EventService) PushEvent(ctx context.Context, r *eventv1.PushEventRequest) (*eventv1.PushEventResponse, error)
• type EventServiceClient
  • func (x *EventServiceClient) PushEvent(ctx context.Context, r *eventv1.PushEventRequest) (*eventv1.PushEventResponse, error)
• type EventServiceHandler
  • func (x *EventServiceHandler) Mount(r chi.Router)
  • func (x *EventServiceHandler) PushEvent(ctx context.Context, r *connect.Request[eventv1.PushEventRequest]) (*connect.Response[eventv1.PushEventResponse], error)
• type PubsubEventServiceClient
  • func (x *PubsubEventServiceClient) PushEvent(ctx context.Context, r *eventv1.PushEventRequest) (*eventv1.PushEventResponse, error)
• type PubsubEventServiceClientConfig

Variables

var (
	// ErrMissingTopic is returned by NewPubsubEventServiceClient when the topic argument is not provided.
	ErrMissingTopic = fmt.Errorf("no topic")
	// ErrMissingProject is returned by NewPubsubEventServiceClient when the project argument is not provided.
	ErrMissingProject = fmt.Errorf("no project")
)

Functions

func NewEventServiceClient

func NewEventServiceClient(uri string, options ...connect.ClientOption) eventv1.EventServiceClient

NewEventServiceClient creates a new cloud.event.v1.EventServiceClient client.

func NewPubsubEventServiceClient

func NewPubsubEventServiceClient(ctx context.Context, config *PubsubEventServiceClientConfig) (eventv1.EventServiceClient, error)

NewPubsubEventServiceClient creates a new cloud.event.v1.EventServiceClient client.

Types

type EventPubsubService

type EventPubsubService struct {
	// EventService contains an instance of cloud.event.v1.EventService service.
	EventService eventv1.EventService
}

EventPubsubService is an implementation of the google.pubsub.v1.EventPubsubService service.

func (*EventPubsubService) PushPubsubMessage

func (x *EventPubsubService) PushPubsubMessage(ctx context.Context, r *pubsubv1.PushPubsubMessageRequest) (*pubsubv1.PushPubsubMessageResponse, error)

PushPubsubMessage implements google.pubsub.v1.PubsubService.

type EventService

type EventService struct {
	// EventService contains an instance of cloud.event.v1.EventHandler handler.
	EventHandler eventv1.EventHandler
}

EventService represents a handler of cloud.event.v1.EventService service.

func (*EventService) PushEvent

func (x *EventService) PushEvent(ctx context.Context, r *eventv1.PushEventRequest) (*eventv1.PushEventResponse, error)

PushEvent implements eventv1.EventService.

type EventServiceClient

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

EventServiceClient is a client for the cloud.event.v1.EventService service.

func (*EventServiceClient) PushEvent

func (x *EventServiceClient) PushEvent(ctx context.Context, r *eventv1.PushEventRequest) (*eventv1.PushEventResponse, error)

PushEventEvent implements cloud.event.v1.EventServiceClient.

type EventServiceHandler

type EventServiceHandler struct {
	// EventService contains an instance of cloud.event.v1.EventService service.
	EventService eventv1.EventService
}

EventServiceHandler represents an instance of cloud.event.v1.EventServiceHandler handler.

func (*EventServiceHandler) Mount

func (x *EventServiceHandler) Mount(r chi.Router)

Mount mounts the controller to a given router.

func (*EventServiceHandler) PushEvent

func (x *EventServiceHandler) PushEvent(ctx context.Context, r *connect.Request[eventv1.PushEventRequest]) (*connect.Response[eventv1.PushEventResponse], error)

PushEvent pushes a given event to connect.runtime.v1.EventService service.

type PubsubEventServiceClient

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

EventServiceConn is a client for the cloud.event.v1.EventService service.

func (*PubsubEventServiceClient) PushEvent

func (x *PubsubEventServiceClient) PushEvent(ctx context.Context, r *eventv1.PushEventRequest) (*eventv1.PushEventResponse, error)

PushEvent pushes a given event to cloud.event.v1.EventService service.

type PubsubEventServiceClientConfig

type PubsubEventServiceClientConfig struct {
	// Project is the Google Cloud Project
	Project string
	// Topic is the Google Pub/Sub Topic
	Topic string
	// Options contains the client Options
	Options []option.ClientOption
}

PubsubEventServiceClientConfig represents a configuration for the cloud.event.v1.PubsubServiceClient client.