service

Documentation

Index

• type Message
  • func NewManage(db *sqlx.DB, logger *logger.Logger, bot *rulebot.RuleBot, webhook string, ...) *Message
  • func (m *Message) Create(_ context.Context, payload *pb.MessageRequest) (*pb.TextsReply, error)
  • func (m *Message) CreateActionMessage(ctx context.Context, payload *pb.TextRequest) (*pb.StateReply, error)
  • func (m *Message) CreateScriptMessage(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) GetScriptMessages(_ context.Context, _ *pb.TextRequest) (*pb.ScriptsReply, error)
  • func (m *Message) List(_ context.Context, _ *pb.MessageRequest) (*pb.MessageListReply, 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)

Types

type Message

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

func NewManage

func NewManage(db *sqlx.DB, logger *logger.Logger, bot *rulebot.RuleBot, webhook string, wfClient pb.WorkflowClient) *Message

func (*Message) Create

func (m *Message) Create(_ context.Context, payload *pb.MessageRequest) (*pb.TextsReply, error)

func (*Message) CreateActionMessage

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

func (*Message) CreateScriptMessage

func (m *Message) CreateScriptMessage(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) GetScriptMessages

func (m *Message) GetScriptMessages(_ context.Context, _ *pb.TextRequest) (*pb.ScriptsReply, error)

func (*Message) List

func (m *Message) List(_ context.Context, _ *pb.MessageRequest) (*pb.MessageListReply, 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)