listen

Documentation

Index

• Constants
• func ConfigurationAPI(ctx context.Context, logger logr.Logger, serverFlags *gateway.ServerFlags, ...) error
• func NewListenCommand(logger *logging.Logger) *cobra.Command
• func NewResponder(ctx context.Context, logger logr.Logger, store responses.Store) (*responses.Responder, error)
• type ResponsesConfigurationServer
  • func (w ResponsesConfigurationServer) Create(ctx context.Context, req *protoResponses.CreateRequest) (*protoResponses.CreateResponse, error)
  • func (w ResponsesConfigurationServer) Delete(ctx context.Context, req *protoResponses.DeleteRequest) (*protoResponses.DeleteResponse, error)
  • func (w ResponsesConfigurationServer) List(ctx context.Context, req *protoResponses.ListRequest) (*protoResponses.ListResponse, error)
  • func (w ResponsesConfigurationServer) Read(ctx context.Context, req *protoResponses.ReadRequest) (*protoResponses.Response, error)
  • func (w ResponsesConfigurationServer) Update(ctx context.Context, req *protoResponses.UpdateRequest) (*protoResponses.UpdateResponse, error)

Constants

const (
	QueueName string = "responder"
)

Functions

func ConfigurationAPI

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

func NewListenCommand

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

func NewResponder

func NewResponder(ctx context.Context, logger logr.Logger, store responses.Store) (*responses.Responder, error)

Types

type ResponsesConfigurationServer

type ResponsesConfigurationServer struct {
	protoResponses.UnimplementedResponsesConfigurationServer
	grpcUtils.DisabledAuth
	// contains filtered or unexported fields
}

func (ResponsesConfigurationServer) Create

func (w ResponsesConfigurationServer) Create(ctx context.Context, req *protoResponses.CreateRequest) (*protoResponses.CreateResponse, error)

func (ResponsesConfigurationServer) Delete

func (w ResponsesConfigurationServer) Delete(ctx context.Context, req *protoResponses.DeleteRequest) (*protoResponses.DeleteResponse, error)

func (ResponsesConfigurationServer) List

func (w ResponsesConfigurationServer) List(ctx context.Context, req *protoResponses.ListRequest) (*protoResponses.ListResponse, error)

func (ResponsesConfigurationServer) Read

func (w ResponsesConfigurationServer) Read(ctx context.Context, req *protoResponses.ReadRequest) (*protoResponses.Response, error)

func (ResponsesConfigurationServer) Update

func (w ResponsesConfigurationServer) Update(ctx context.Context, req *protoResponses.UpdateRequest) (*protoResponses.UpdateResponse, error)