Documentation
¶
Index ¶
- func FromPbAddSubscription(sub *pbtrigger.AddSubscriptionRequest) *primitive.Subscription
- func FromPbOffsetInfos(offsets []*pb.OffsetInfo) info.ListOffsetInfo
- func FromPbSubscriptionRequest(sub *ctrl.SubscriptionRequest) *metadata.Subscription
- func ToPbAddSubscription(sub *primitive.Subscription) *pbtrigger.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(sub *pbtrigger.AddSubscriptionRequest) *primitive.Subscription
func FromPbOffsetInfos ¶
func FromPbOffsetInfos(offsets []*pb.OffsetInfo) info.ListOffsetInfo
func FromPbSubscriptionRequest ¶
func FromPbSubscriptionRequest(sub *ctrl.SubscriptionRequest) *metadata.Subscription
func ToPbAddSubscription ¶
func ToPbAddSubscription(sub *primitive.Subscription) *pbtrigger.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.