dapr

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

type CloudEvent struct {
	ID              string          `json:"id"`
	Source          string          `json:"source"`
	SpecVersion     string          `json:"specversion"`
	Type            string          `json:"type"`
	DataContentType string          `json:"datacontenttype,omitempty"`
	DataSchema      string          `json:"dataschema,omitempty"`
	Subject         string          `json:"subject,omitempty"`
	Time            time.Time       `json:"time,omitempty"`
	Data            json.RawMessage `json:"data"`
}

type Events interface {
	RegisterEventHandlers(app *fiber.App)
}

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

type HTTP struct{}

type HandlerRegistrar interface {
	RegisterTopicEventHandlers(register RegisterEventHandler)
}

type RegisterEventHandler func(path string, handler TopicEventHandler)

type Routes struct {
	Rules   []Rule `json:"rules,omitempty"`
	Default string `json:"default,omitempty"`
}

type Rule struct {
	Match string `json:"match"`
	Path  string `json:"path"`
}

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

type Service interface {
	RegisterService(app *fiber.App)
}

type Subscriber interface {
	Subscriptions() []Subscription
}

type Subscription struct {
	PubsubName string            `json:"pubsubname"`
	Topic      string            `json:"topic"`
	Metadata   map[string]string `json:"metadata,omitempty"`
	Routes     Routes            `json:"routes"`
}

type TopicEventHandler func(ctx context.Context, in *pb.TopicEventRequest) (*pb.TopicEventResponse, error)