tntcontrollers

Documentation

Index

• func Init(log *zap.Logger, rateOpt *config.RateOptions, jwtOpt *config.JWTOptions, ...) error
• func InitTest(log *zap.Logger, rateOpt *config.RateOptions, jwtOpt *config.JWTOptions, ...) error
• type EventController
  • func NewEventController(log *zap.Logger, userServiceClient partyproto.UserServiceClient, ...) *EventController
  • func (ec *EventController) GetEvent(ctx context.Context, w http.ResponseWriter, r *http.Request, id string, ...)
  • func (ec *EventController) GetEvents(ctx context.Context, w http.ResponseWriter, r *http.Request, limit string, ...)
  • func (ec *EventController) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type EventSubscriptionController
  • func NewEventSubscriptionController(log *zap.Logger, userServiceClient partyproto.UserServiceClient, ...) *EventSubscriptionController
  • func (esc *EventSubscriptionController) CreateEventSubscription(ctx context.Context, w http.ResponseWriter, r *http.Request, ...)
  • func (esc *EventSubscriptionController) DeleteEventSubscription(ctx context.Context, w http.ResponseWriter, r *http.Request, id string, ...)
  • func (esc *EventSubscriptionController) GetEventSubscriptionByCarrierEventSubscriptionRequestReference(ctx context.Context, w http.ResponseWriter, r *http.Request, id string, ...)
  • func (esc *EventSubscriptionController) GetEventSubscriptions(ctx context.Context, w http.ResponseWriter, r *http.Request, limit string, ...)
  • func (esc *EventSubscriptionController) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func Init

func Init(log *zap.Logger, rateOpt *config.RateOptions, jwtOpt *config.JWTOptions, mux *http.ServeMux, store *goredisstore.GoRedisStore, serverOpt *config.ServerOptions, grpcServerOpt *config.GrpcServerOptions, uptraceOpt *config.UptraceOptions, configFilePath string) error

Init the tnt controllers

func InitTest

func InitTest(log *zap.Logger, rateOpt *config.RateOptions, jwtOpt *config.JWTOptions, mux *http.ServeMux, store *goredisstore.GoRedisStore, serverOpt *config.ServerOptions, grpcServerOpt *config.GrpcServerOptions, uptraceOpt *config.UptraceOptions, configFilePath string) error

InitTest the tnt controllers

Types

type EventController

type EventController struct {
	UserServiceClient  partyproto.UserServiceClient
	EventServiceClient tntproto.EventServiceClient
	// contains filtered or unexported fields
}

EventController - Create Event Controller

func NewEventController

func NewEventController(log *zap.Logger, userServiceClient partyproto.UserServiceClient, eventServiceClient tntproto.EventServiceClient) *EventController

NewEventController - Create Event Handler

func (*EventController) GetEvent

func (ec *EventController) GetEvent(ctx context.Context, w http.ResponseWriter, r *http.Request, id string, user *partyproto.GetAuthUserDetailsResponse)

func (*EventController) GetEvents

func (ec *EventController) GetEvents(ctx context.Context, w http.ResponseWriter, r *http.Request, limit string, cursor string, user *partyproto.GetAuthUserDetailsResponse)

GetEvents - list Event Headers

func (*EventController) ServeHTTP

func (ec *EventController) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP - parse url and call controller action

type EventSubscriptionController

type EventSubscriptionController struct {
	UserServiceClient              partyproto.UserServiceClient
	EventSubscriptionServiceClient tntproto.EventSubscriptionServiceClient
	// contains filtered or unexported fields
}

EventSubscriptionController - Create EventSubscription Controller

func NewEventSubscriptionController

func NewEventSubscriptionController(log *zap.Logger, userServiceClient partyproto.UserServiceClient, eventSubscriptionServiceClient tntproto.EventSubscriptionServiceClient, wfHelper common.WfHelper, workflowClient client.Client) *EventSubscriptionController

NewEventSubscriptionController - Create EventSubscription Handler

func (*EventSubscriptionController) CreateEventSubscription

func (esc *EventSubscriptionController) CreateEventSubscription(ctx context.Context, w http.ResponseWriter, r *http.Request, user *partyproto.GetAuthUserDetailsResponse, tokenString string)

CreateEventSubscription - Create EventSubscription Header

func (*EventSubscriptionController) DeleteEventSubscription

func (esc *EventSubscriptionController) DeleteEventSubscription(ctx context.Context, w http.ResponseWriter, r *http.Request, id string, user *partyproto.GetAuthUserDetailsResponse)

DeleteEventSubscription - DeleteEventSubscription

func (*EventSubscriptionController) GetEventSubscriptionByCarrierEventSubscriptionRequestReference

func (esc *EventSubscriptionController) GetEventSubscriptionByCarrierEventSubscriptionRequestReference(ctx context.Context, w http.ResponseWriter, r *http.Request, id string, user *partyproto.GetAuthUserDetailsResponse)

GetEventSubscriptionByCarrierEventSubscriptionRequestReference - GetEventSubscriptionByCarrierEventSubscriptionRequestReference EventSubscription

func (*EventSubscriptionController) GetEventSubscriptions

func (esc *EventSubscriptionController) GetEventSubscriptions(ctx context.Context, w http.ResponseWriter, r *http.Request, limit string, cursor string, user *partyproto.GetAuthUserDetailsResponse)

GetEventSubscriptions - used to view all EventSubscription

func (*EventSubscriptionController) ServeHTTP

func (esc *EventSubscriptionController) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP - parse url and call controller action