service

Documentation

Index

• type Message
  • func NewManage(db *sqlx.DB, logger *zap.Logger, bot *rulebot.RuleBot, webhook string, ...) *Message
  • func (m *Message) Create(ctx context.Context, payload *pb.MessageRequest) (*pb.MessageReply, error)
  • func (m *Message) Delete(ctx context.Context, payload *pb.MessageRequest) (*pb.TextReply, error)
  • func (m *Message) Get(ctx context.Context, payload *pb.MessageRequest) (*pb.TextReply, error)
  • func (m *Message) List(ctx context.Context, payload *pb.MessageRequest) (*pb.MessageListReply, error)
  • func (m *Message) Run(ctx context.Context, payload *pb.MessageRequest) (*pb.TextReply, error)
  • func (m *Message) Send(ctx context.Context, payload *pb.MessageRequest) (*pb.TextReply, error)

Types

type Message

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

func NewManage

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

func (*Message) Create

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

func (*Message) Delete

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

func (*Message) Get

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

func (*Message) List

func (m *Message) List(ctx context.Context, payload *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(ctx context.Context, payload *pb.MessageRequest) (*pb.TextReply, error)