Documentation
¶
Index ¶
- func FromPbAddSubscription(req *triggerpb.AddSubscriptionRequest) (*primitive.Subscription, error)
- func FromPbOffsetInfos(offsets []*pb.OffsetInfo) info.ListOffsetInfo
- func FromPbSubscriptionRequest(sub *ctrl.SubscriptionRequest) (*metadata.Subscription, error)
- func FromPbTemplateType(t pb.TemplateType) (primitive.TemplateType, error)
- func ToPbAddSubscription(sub *primitive.Subscription) *triggerpb.AddSubscriptionRequest
- func ToPbOffsetInfos(offsets info.ListOffsetInfo) []*pb.OffsetInfo
- func ToPbSubscription(sub *metadata.Subscription, offsets info.ListOffsetInfo) *pb.Subscription
- func ToPbSubscriptionInfo(sub info.SubscriptionInfo) *pb.SubscriptionInfo
- func ToPbTransformer(transformer *primitive.Transformer) *pb.Transformer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FromPbAddSubscription ¶
func FromPbAddSubscription(req *triggerpb.AddSubscriptionRequest) (*primitive.Subscription, error)
func FromPbOffsetInfos ¶
func FromPbOffsetInfos(offsets []*pb.OffsetInfo) info.ListOffsetInfo
func FromPbSubscriptionRequest ¶
func FromPbSubscriptionRequest(sub *ctrl.SubscriptionRequest) (*metadata.Subscription, error)
func FromPbTemplateType ¶ added in v0.9.0
func FromPbTemplateType(t pb.TemplateType) (primitive.TemplateType, error)
func ToPbAddSubscription ¶
func ToPbAddSubscription(sub *primitive.Subscription) *triggerpb.AddSubscriptionRequest
func ToPbOffsetInfos ¶
func ToPbOffsetInfos(offsets info.ListOffsetInfo) []*pb.OffsetInfo
func ToPbSubscription ¶
func ToPbSubscription(sub *metadata.Subscription, offsets info.ListOffsetInfo) *pb.Subscription
func ToPbSubscriptionInfo ¶
func ToPbSubscriptionInfo(sub info.SubscriptionInfo) *pb.SubscriptionInfo
func ToPbTransformer ¶
func ToPbTransformer(transformer *primitive.Transformer) *pb.Transformer
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.