service

Documentation

Index

• func GRPCMiddleware() []grpc.UnaryServerInterceptor
• func NewDeadmessagePSM() (*dante_pb.DeadmessagePSM, error)
• type DeadLetterWorker
  • func NewDeadLetterWorker(conn sqrlx.Connection, stateMachine *dante_pb.DeadmessagePSM, slack string) (*DeadLetterWorker, error)
  • func (ds *DeadLetterWorker) Dead(ctx context.Context, req *messaging_tpb.DeadMessage) (*emptypb.Empty, error)
• type DeadletterService
  • func NewDeadletterServiceService(conn sqrlx.Connection, statemachine *dante_pb.DeadmessagePSM, ...) (*DeadletterService, error)
  • func (ds *DeadletterService) GetDeadMessage(ctx context.Context, req *dante_spb.GetDeadMessageRequest) (*dante_spb.GetDeadMessageResponse, error)
  • func (ds *DeadletterService) ListDeadMessageEvents(ctx context.Context, req *dante_spb.ListDeadMessageEventsRequest) (*dante_spb.ListDeadMessageEventsResponse, error)
  • func (ds *DeadletterService) ListDeadMessages(ctx context.Context, req *dante_spb.ListDeadMessagesRequest) (*dante_spb.ListDeadMessagesResponse, error)
  • func (ds *DeadletterService) RejectDeadMessage(ctx context.Context, req *dante_spb.RejectDeadMessageRequest) (*dante_spb.RejectDeadMessageResponse, error)
  • func (ds *DeadletterService) ReplayDeadMessage(ctx context.Context, req *dante_spb.ReplayDeadMessageRequest) (*dante_spb.ReplayDeadMessageResponse, error)
  • func (ds *DeadletterService) UpdateDeadMessage(ctx context.Context, req *dante_spb.UpdateDeadMessageRequest) (*dante_spb.UpdateDeadMessageResponse, error)
• type ProtoJSON
• type SlackMessage
• type SqsSender

Functions

func GRPCMiddleware

func GRPCMiddleware() []grpc.UnaryServerInterceptor

func NewDeadmessagePSM

func NewDeadmessagePSM() (*dante_pb.DeadmessagePSM, error)

Types

type DeadLetterWorker

type DeadLetterWorker struct {
	messaging_tpb.UnimplementedDeadMessageTopicServer
	// contains filtered or unexported fields
}

func NewDeadLetterWorker

func NewDeadLetterWorker(conn sqrlx.Connection, stateMachine *dante_pb.DeadmessagePSM, slack string) (*DeadLetterWorker, error)

func (*DeadLetterWorker) Dead

func (ds *DeadLetterWorker) Dead(ctx context.Context, req *messaging_tpb.DeadMessage) (*emptypb.Empty, error)

type DeadletterService

type DeadletterService struct {
	dante_spb.UnimplementedDeadMessageQueryServiceServer
	dante_spb.UnimplementedDeadMessageCommandServiceServer
	// contains filtered or unexported fields
}

func NewDeadletterServiceService

func NewDeadletterServiceService(conn sqrlx.Connection, statemachine *dante_pb.DeadmessagePSM, sqsClient SqsSender) (*DeadletterService, error)

func (*DeadletterService) GetDeadMessage

func (ds *DeadletterService) GetDeadMessage(ctx context.Context, req *dante_spb.GetDeadMessageRequest) (*dante_spb.GetDeadMessageResponse, error)

func (*DeadletterService) ListDeadMessageEvents

func (ds *DeadletterService) ListDeadMessageEvents(ctx context.Context, req *dante_spb.ListDeadMessageEventsRequest) (*dante_spb.ListDeadMessageEventsResponse, error)

func (*DeadletterService) ListDeadMessages

func (ds *DeadletterService) ListDeadMessages(ctx context.Context, req *dante_spb.ListDeadMessagesRequest) (*dante_spb.ListDeadMessagesResponse, error)

func (*DeadletterService) RejectDeadMessage

func (ds *DeadletterService) RejectDeadMessage(ctx context.Context, req *dante_spb.RejectDeadMessageRequest) (*dante_spb.RejectDeadMessageResponse, error)

func (*DeadletterService) ReplayDeadMessage

func (ds *DeadletterService) ReplayDeadMessage(ctx context.Context, req *dante_spb.ReplayDeadMessageRequest) (*dante_spb.ReplayDeadMessageResponse, error)

func (*DeadletterService) UpdateDeadMessage

func (ds *DeadletterService) UpdateDeadMessage(ctx context.Context, req *dante_spb.UpdateDeadMessageRequest) (*dante_spb.UpdateDeadMessageResponse, error)

type ProtoJSON

type ProtoJSON interface {
	Marshal(v proto.Message) ([]byte, error)
	Unmarshal(data []byte, v proto.Message) error
}

type SlackMessage

type SlackMessage struct {
	Text string `json:"text"`
}

type SqsSender

type SqsSender interface {
	SendMessage(ctx context.Context, params *sqs.SendMessageInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)
}