publish

Documentation

Index

• type Codec
• type EventLog
• type MissingCodecError
  • func (m *MissingCodecError) Error() string
• type Service
  • func NewService(client daprd.Client) *Service
  • func (s *Service) ListInputBindings(_ context.Context, _ *emptypb.Empty) (*pb.ListInputBindingsResponse, error)
  • func (s *Service) ListTopicSubscriptions(context.Context, *emptypb.Empty) (*pb.ListTopicSubscriptionsResponse, error)
  • func (s *Service) OnBindingEvent(ctx context.Context, request *pb.BindingEventRequest) (*pb.BindingEventResponse, error)
  • func (s *Service) RegisterCodec(c Codec)

Types

type Codec

type Codec interface {
	Convert(record *EventLog) (proto.Message, error)
	Aggregate() string
}

type EventLog

type EventLog struct {
	ID        string
	Sequence  int64
	Type      string
	Timestamp int64
	Aggregate string
	Data      []byte
}

type MissingCodecError

type MissingCodecError struct {
	Aggregate string
}

func (*MissingCodecError) Error

func (m *MissingCodecError) Error() string

type Service

type Service struct {
	pb.UnimplementedAppCallbackServer
	// contains filtered or unexported fields
}

func NewService

func NewService(client daprd.Client) *Service

func (*Service) ListInputBindings

func (s *Service) ListInputBindings(_ context.Context, _ *emptypb.Empty) (*pb.ListInputBindingsResponse, error)

func (*Service) ListTopicSubscriptions

func (s *Service) ListTopicSubscriptions(context.Context, *emptypb.Empty) (*pb.ListTopicSubscriptionsResponse, error)

func (*Service) OnBindingEvent

func (s *Service) OnBindingEvent(ctx context.Context, request *pb.BindingEventRequest) (*pb.BindingEventResponse, error)

func (*Service) RegisterCodec

func (s *Service) RegisterCodec(c Codec)