app

Documentation

Index

• func NewDataGatherCommand() *cobra.Command
• type DataGather
  • func NewDataGather(conf *DataGatherConfig) (*DataGather, error)
  • func (dg *DataGather) Start() error
• type DataGatherConfig
• type DataGatherService
• type DatagatherService
  • func NewDatagatherService(producers []*queue.EmbeddedQueueProducer) *DatagatherService
  • func (ds *DatagatherService) CreateEvent(ctx context.Context, req *service.CreateEventRequest) (*types.Empty, error)
  • func (ds *DatagatherService) CreateItem(ctx context.Context, req *service.CreateItemRequest) (*types.Empty, error)
  • func (ds *DatagatherService) CreateUser(ctx context.Context, req *service.CreateUserRequest) (*types.Empty, error)
  • func (ds *DatagatherService) DeleteItem(ctx context.Context, req *service.DeleteItemRequest) (*types.Empty, error)
  • func (ds *DatagatherService) DeleteUser(ctx context.Context, req *service.DeleteUserRequest) (*types.Empty, error)
  • func (ds *DatagatherService) RegisterService(grpcServer *grpc.Server)
  • func (ds *DatagatherService) UpdateItem(ctx context.Context, req *service.UpdateItemRequest) (*types.Empty, error)
  • func (ds *DatagatherService) UpdateUser(ctx context.Context, req *service.UpdateUserRequest) (*types.Empty, error)

Functions

func NewDataGatherCommand

func NewDataGatherCommand() *cobra.Command

Types

type DataGather

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

func NewDataGather

func NewDataGather(conf *DataGatherConfig) (*DataGather, error)

func (*DataGather) Start

func (dg *DataGather) Start() error

type DataGatherConfig

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

type DataGatherService

type DataGatherService interface {
	Start() error
	Stop() error
}

type DatagatherService

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

func NewDatagatherService

func NewDatagatherService(producers []*queue.EmbeddedQueueProducer) *DatagatherService

func (*DatagatherService) CreateEvent

func (ds *DatagatherService) CreateEvent(ctx context.Context, req *service.CreateEventRequest) (*types.Empty, error)

func (*DatagatherService) CreateItem

func (ds *DatagatherService) CreateItem(ctx context.Context, req *service.CreateItemRequest) (*types.Empty, error)

func (*DatagatherService) CreateUser

func (ds *DatagatherService) CreateUser(ctx context.Context, req *service.CreateUserRequest) (*types.Empty, error)

func (*DatagatherService) DeleteItem

func (ds *DatagatherService) DeleteItem(ctx context.Context, req *service.DeleteItemRequest) (*types.Empty, error)

func (*DatagatherService) DeleteUser

func (ds *DatagatherService) DeleteUser(ctx context.Context, req *service.DeleteUserRequest) (*types.Empty, error)

func (*DatagatherService) RegisterService

func (ds *DatagatherService) RegisterService(grpcServer *grpc.Server)

func (*DatagatherService) UpdateItem

func (ds *DatagatherService) UpdateItem(ctx context.Context, req *service.UpdateItemRequest) (*types.Empty, error)

func (*DatagatherService) UpdateUser

func (ds *DatagatherService) UpdateUser(ctx context.Context, req *service.UpdateUserRequest) (*types.Empty, error)