listen

Documentation

Index

• Constants
• func ConfigurationAPI(ctx context.Context, logger logr.Logger, serverFlags *gateway.ServerFlags, ...) error
• func NewListenCommand(logger *logging.Logger) *cobra.Command
• func NewWebhookStore(ctx context.Context, db *sqlx.DB) (webhooks.Store, error)
• type WebhookConfigurationServer
  • func (w WebhookConfigurationServer) Create(ctx context.Context, req *webhookd.CreateRequest) (*webhookd.CreateResponse, error)
  • func (w WebhookConfigurationServer) Delete(ctx context.Context, req *webhookd.DeleteRequest) (*webhookd.DeleteResponse, error)
  • func (w WebhookConfigurationServer) List(ctx context.Context, req *webhookd.ListRequest) (*webhookd.ListResponse, error)
  • func (w WebhookConfigurationServer) Read(ctx context.Context, req *webhookd.ReadRequest) (*webhookd.Webhook, error)
  • func (w WebhookConfigurationServer) Update(ctx context.Context, req *webhookd.UpdateRequest) (*webhookd.UpdateResponse, error)

Constants

const (
	QueueName string = "webhook"
)

Functions

func ConfigurationAPI

func ConfigurationAPI(ctx context.Context, logger logr.Logger, serverFlags *gateway.ServerFlags, store webhooks.Store) error

func NewListenCommand

func NewListenCommand(logger *logging.Logger) *cobra.Command

func NewWebhookStore

func NewWebhookStore(ctx context.Context, db *sqlx.DB) (webhooks.Store, error)

Types

type WebhookConfigurationServer

type WebhookConfigurationServer struct {
	webhookd.UnimplementedWebhookConfigurationServer
	grpcUtils.DisabledAuth
	// contains filtered or unexported fields
}

func (WebhookConfigurationServer) Create

func (w WebhookConfigurationServer) Create(ctx context.Context, req *webhookd.CreateRequest) (*webhookd.CreateResponse, error)

func (WebhookConfigurationServer) Delete

func (w WebhookConfigurationServer) Delete(ctx context.Context, req *webhookd.DeleteRequest) (*webhookd.DeleteResponse, error)

func (WebhookConfigurationServer) List

func (w WebhookConfigurationServer) List(ctx context.Context, req *webhookd.ListRequest) (*webhookd.ListResponse, error)

func (WebhookConfigurationServer) Read

func (w WebhookConfigurationServer) Read(ctx context.Context, req *webhookd.ReadRequest) (*webhookd.Webhook, error)

func (WebhookConfigurationServer) Update

func (w WebhookConfigurationServer) Update(ctx context.Context, req *webhookd.UpdateRequest) (*webhookd.UpdateResponse, error)