service

Documentation

Index

• Variables
• func CreateInitServerFn(ps *Message) rpc.InitServer
• type Message
  • func NewMessage(bus event.Bus, logger log.Logger, config *config.AppConfig, ...) *Message
  • func (m *Message) Create(ctx context.Context, payload *pb.MessageRequest) (*pb.MessageReply, error)
  • func (m *Message) CreateActionMessage(ctx context.Context, payload *pb.TextRequest) (*pb.StateReply, error)
  • func (m *Message) Delete(_ context.Context, payload *pb.MessageRequest) (*pb.TextReply, error)
  • func (m *Message) DeleteWorkflowMessage(ctx context.Context, payload *pb.MessageRequest) (*pb.StateReply, error)
  • func (m *Message) Get(_ context.Context, payload *pb.MessageRequest) (*pb.MessageReply, error)
  • func (m *Message) GetActionMessages(_ context.Context, _ *pb.TextRequest) (*pb.ActionReply, error)
  • func (m *Message) List(_ context.Context, _ *pb.MessageRequest) (*pb.MessagesReply, error)
  • func (m *Message) Run(ctx context.Context, payload *pb.MessageRequest) (*pb.TextReply, error)
  • func (m *Message) Send(_ context.Context, payload *pb.MessageRequest) (*pb.StateReply, error)

Variables

var ProviderSet = wire.NewSet(NewMessage, CreateInitServerFn)

Functions

func CreateInitServerFn

func CreateInitServerFn(ps *Message) rpc.InitServer

Types

type Message

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

func NewMessage

func NewMessage(
	bus event.Bus,
	logger log.Logger,
	config *config.AppConfig,
	repo repository.MessageRepository,
	workflow pb.WorkflowSvcClient) *Message

func (*Message) Create

func (m *Message) Create(ctx context.Context, payload *pb.MessageRequest) (*pb.MessageReply, error)

func (*Message) CreateActionMessage

func (m *Message) CreateActionMessage(ctx context.Context, payload *pb.TextRequest) (*pb.StateReply, error)

func (*Message) Delete

func (m *Message) Delete(_ context.Context, payload *pb.MessageRequest) (*pb.TextReply, error)

func (*Message) DeleteWorkflowMessage

func (m *Message) DeleteWorkflowMessage(ctx context.Context, payload *pb.MessageRequest) (*pb.StateReply, error)

func (*Message) Get

func (m *Message) Get(_ context.Context, payload *pb.MessageRequest) (*pb.MessageReply, error)

func (*Message) GetActionMessages

func (m *Message) GetActionMessages(_ context.Context, _ *pb.TextRequest) (*pb.ActionReply, error)

func (*Message) List

func (m *Message) List(_ context.Context, _ *pb.MessageRequest) (*pb.MessagesReply, error)

func (*Message) Run

func (m *Message) Run(ctx context.Context, payload *pb.MessageRequest) (*pb.TextReply, error)

func (*Message) Send

func (m *Message) Send(_ context.Context, payload *pb.MessageRequest) (*pb.StateReply, error)