Documentation
¶
Index ¶
- Variables
- func CreateInitServerFn(ps *Message) rpc.InitServer
- type 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(ctx 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(ctx context.Context, payload *pb.MessageRequest) (*pb.MessageReply, error)
- func (m *Message) GetActionMessages(ctx context.Context, _ *pb.TextRequest) (*pb.ActionReply, error)
- func (m *Message) List(ctx 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)
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet(NewMessage, CreateInitServerFn)
Functions ¶
func CreateInitServerFn ¶ added in v0.0.24
func CreateInitServerFn(ps *Message) rpc.InitServer
Types ¶
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
func NewMessage ¶ added in v0.0.24
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 ¶ added in v0.0.17
func (m *Message) CreateActionMessage(ctx context.Context, payload *pb.TextRequest) (*pb.StateReply, error)
func (*Message) DeleteWorkflowMessage ¶ added in v0.0.18
func (m *Message) DeleteWorkflowMessage(ctx context.Context, payload *pb.MessageRequest) (*pb.StateReply, error)
func (*Message) Get ¶
func (m *Message) Get(ctx context.Context, payload *pb.MessageRequest) (*pb.MessageReply, error)
func (*Message) GetActionMessages ¶ added in v0.0.17
func (m *Message) GetActionMessages(ctx context.Context, _ *pb.TextRequest) (*pb.ActionReply, error)
func (*Message) List ¶
func (m *Message) List(ctx context.Context, _ *pb.MessageRequest) (*pb.MessagesReply, error)
func (*Message) Send ¶
func (m *Message) Send(_ context.Context, payload *pb.MessageRequest) (*pb.StateReply, error)
Source Files
Click to show internal directories.
Click to hide internal directories.