Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterFeedServer(s grpc.ServiceRegistrar, srv FeedServer)
- func RegisterSubscriberServer(s grpc.ServiceRegistrar, srv SubscriberServer)
- func RegisterSubscriptionServer(s grpc.ServiceRegistrar, srv SubscriptionServer)
- type CreateSubscriberRequest
- func (*CreateSubscriberRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSubscriberRequest) GetWebhookUrl() string
- func (*CreateSubscriberRequest) ProtoMessage()
- func (x *CreateSubscriberRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSubscriberRequest) Reset()
- func (x *CreateSubscriberRequest) String() string
- type CreateSubscriberResponse
- func (*CreateSubscriberResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSubscriberResponse) GetSubscriberId() string
- func (*CreateSubscriberResponse) ProtoMessage()
- func (x *CreateSubscriberResponse) ProtoReflect() protoreflect.Message
- func (x *CreateSubscriberResponse) Reset()
- func (x *CreateSubscriberResponse) String() string
- type FeedByFilterRequest
- func (*FeedByFilterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FeedByFilterRequest) GetActions() []string
- func (x *FeedByFilterRequest) GetDaoId() stringdeprecated
- func (x *FeedByFilterRequest) GetDaoIds() []string
- func (x *FeedByFilterRequest) GetIsActive() bool
- func (x *FeedByFilterRequest) GetLimit() uint64
- func (x *FeedByFilterRequest) GetOffset() uint64
- func (x *FeedByFilterRequest) GetTypes() []string
- func (*FeedByFilterRequest) ProtoMessage()
- func (x *FeedByFilterRequest) ProtoReflect() protoreflect.Message
- func (x *FeedByFilterRequest) Reset()
- func (x *FeedByFilterRequest) String() string
- type FeedByFilterResponse
- func (*FeedByFilterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FeedByFilterResponse) GetItems() []*FeedInfo
- func (x *FeedByFilterResponse) GetTotalCount() uint64
- func (*FeedByFilterResponse) ProtoMessage()
- func (x *FeedByFilterResponse) ProtoReflect() protoreflect.Message
- func (x *FeedByFilterResponse) Reset()
- func (x *FeedByFilterResponse) String() string
- type FeedClient
- type FeedInfo
- func (*FeedInfo) Descriptor() ([]byte, []int)deprecated
- func (x *FeedInfo) GetAction() string
- func (x *FeedInfo) GetCreatedAt() *timestamppb.Timestamp
- func (x *FeedInfo) GetDaoId() string
- func (x *FeedInfo) GetDiscussionId() string
- func (x *FeedInfo) GetId() string
- func (x *FeedInfo) GetProposalId() string
- func (x *FeedInfo) GetSnapshot() *anypb.Any
- func (x *FeedInfo) GetTimeline() []*FeedTimelineItem
- func (x *FeedInfo) GetType() FeedInfo_Type
- func (x *FeedInfo) GetUpdatedAt() *timestamppb.Timestamp
- func (*FeedInfo) ProtoMessage()
- func (x *FeedInfo) ProtoReflect() protoreflect.Message
- func (x *FeedInfo) Reset()
- func (x *FeedInfo) String() string
- type FeedInfo_Type
- func (FeedInfo_Type) Descriptor() protoreflect.EnumDescriptor
- func (x FeedInfo_Type) Enum() *FeedInfo_Type
- func (FeedInfo_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x FeedInfo_Type) Number() protoreflect.EnumNumber
- func (x FeedInfo_Type) String() string
- func (FeedInfo_Type) Type() protoreflect.EnumType
- type FeedServer
- type FeedTimelineItem
- func (*FeedTimelineItem) Descriptor() ([]byte, []int)deprecated
- func (x *FeedTimelineItem) GetAction() FeedTimelineItem_TimelineAction
- func (x *FeedTimelineItem) GetCreatedAt() *timestamppb.Timestamp
- func (*FeedTimelineItem) ProtoMessage()
- func (x *FeedTimelineItem) ProtoReflect() protoreflect.Message
- func (x *FeedTimelineItem) Reset()
- func (x *FeedTimelineItem) String() string
- type FeedTimelineItem_TimelineAction
- func (FeedTimelineItem_TimelineAction) Descriptor() protoreflect.EnumDescriptor
- func (x FeedTimelineItem_TimelineAction) Enum() *FeedTimelineItem_TimelineAction
- func (FeedTimelineItem_TimelineAction) EnumDescriptor() ([]byte, []int)deprecated
- func (x FeedTimelineItem_TimelineAction) Number() protoreflect.EnumNumber
- func (x FeedTimelineItem_TimelineAction) String() string
- func (FeedTimelineItem_TimelineAction) Type() protoreflect.EnumType
- type SubscribeRequest
- type SubscriberClient
- type SubscriberServer
- type SubscriptionClient
- type SubscriptionServer
- type UnimplementedFeedServer
- type UnimplementedSubscriberServer
- type UnimplementedSubscriptionServer
- type UnsafeFeedServer
- type UnsafeSubscriberServer
- type UnsafeSubscriptionServer
- type UnsubscribeRequest
- func (*UnsubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnsubscribeRequest) GetDaoId() string
- func (*UnsubscribeRequest) ProtoMessage()
- func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *UnsubscribeRequest) Reset()
- func (x *UnsubscribeRequest) String() string
- type UpdateSubscriberRequest
- func (*UpdateSubscriberRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSubscriberRequest) GetWebhookUrl() string
- func (*UpdateSubscriberRequest) ProtoMessage()
- func (x *UpdateSubscriberRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateSubscriberRequest) Reset()
- func (x *UpdateSubscriberRequest) String() string
Constants ¶
const ( Subscriber_Create_FullMethodName = "/feedpb.Subscriber/Create" Subscriber_Update_FullMethodName = "/feedpb.Subscriber/Update" )
const ( Subscription_Subscribe_FullMethodName = "/feedpb.Subscription/Subscribe" Subscription_Unsubscribe_FullMethodName = "/feedpb.Subscription/Unsubscribe" )
const (
Feed_GetByFilter_FullMethodName = "/feedpb.Feed/GetByFilter"
)
Variables ¶
var ( FeedInfo_Type_name = map[int32]string{ 0: "Unspecified", 1: "DAO", 2: "Proposal", } FeedInfo_Type_value = map[string]int32{ "Unspecified": 0, "DAO": 1, "Proposal": 2, } )
Enum value maps for FeedInfo_Type.
var ( FeedTimelineItem_TimelineAction_name = map[int32]string{ 0: "Unspecified", 1: "DaoCreated", 2: "DaoUpdated", 3: "ProposalCreated", 4: "ProposalUpdated", 5: "ProposalVotingStartsSoon", 6: "ProposalVotingStarted", 7: "ProposalVotingQuorumReached", 8: "ProposalVotingEnded", 9: "ProposalVotingEndsSoon", } FeedTimelineItem_TimelineAction_value = map[string]int32{ "Unspecified": 0, "DaoCreated": 1, "DaoUpdated": 2, "ProposalCreated": 3, "ProposalUpdated": 4, "ProposalVotingStartsSoon": 5, "ProposalVotingStarted": 6, "ProposalVotingQuorumReached": 7, "ProposalVotingEnded": 8, "ProposalVotingEndsSoon": 9, } )
Enum value maps for FeedTimelineItem_TimelineAction.
var Feed_ServiceDesc = grpc.ServiceDesc{ ServiceName: "feedpb.Feed", HandlerType: (*FeedServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetByFilter", Handler: _Feed_GetByFilter_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "feedpb/feed.proto", }
Feed_ServiceDesc is the grpc.ServiceDesc for Feed service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_feedpb_feed_proto protoreflect.FileDescriptor
var File_feedpb_subscriber_proto protoreflect.FileDescriptor
var File_feedpb_subscription_proto protoreflect.FileDescriptor
var Subscriber_ServiceDesc = grpc.ServiceDesc{ ServiceName: "feedpb.Subscriber", HandlerType: (*SubscriberServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _Subscriber_Create_Handler, }, { MethodName: "Update", Handler: _Subscriber_Update_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "feedpb/subscriber.proto", }
Subscriber_ServiceDesc is the grpc.ServiceDesc for Subscriber service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Subscription_ServiceDesc = grpc.ServiceDesc{ ServiceName: "feedpb.Subscription", HandlerType: (*SubscriptionServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Subscribe", Handler: _Subscription_Subscribe_Handler, }, { MethodName: "Unsubscribe", Handler: _Subscription_Unsubscribe_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "feedpb/subscription.proto", }
Subscription_ServiceDesc is the grpc.ServiceDesc for Subscription service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterFeedServer ¶
func RegisterFeedServer(s grpc.ServiceRegistrar, srv FeedServer)
func RegisterSubscriberServer ¶
func RegisterSubscriberServer(s grpc.ServiceRegistrar, srv SubscriberServer)
func RegisterSubscriptionServer ¶
func RegisterSubscriptionServer(s grpc.ServiceRegistrar, srv SubscriptionServer)
Types ¶
type CreateSubscriberRequest ¶
type CreateSubscriberRequest struct { WebhookUrl string `protobuf:"bytes,2,opt,name=webhook_url,json=webhookUrl,proto3" json:"webhook_url,omitempty"` // contains filtered or unexported fields }
func (*CreateSubscriberRequest) Descriptor
deprecated
func (*CreateSubscriberRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSubscriberRequest.ProtoReflect.Descriptor instead.
func (*CreateSubscriberRequest) GetWebhookUrl ¶
func (x *CreateSubscriberRequest) GetWebhookUrl() string
func (*CreateSubscriberRequest) ProtoMessage ¶
func (*CreateSubscriberRequest) ProtoMessage()
func (*CreateSubscriberRequest) ProtoReflect ¶
func (x *CreateSubscriberRequest) ProtoReflect() protoreflect.Message
func (*CreateSubscriberRequest) Reset ¶
func (x *CreateSubscriberRequest) Reset()
func (*CreateSubscriberRequest) String ¶
func (x *CreateSubscriberRequest) String() string
type CreateSubscriberResponse ¶
type CreateSubscriberResponse struct { SubscriberId string `protobuf:"bytes,1,opt,name=subscriber_id,json=subscriberId,proto3" json:"subscriber_id,omitempty"` // contains filtered or unexported fields }
func (*CreateSubscriberResponse) Descriptor
deprecated
func (*CreateSubscriberResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateSubscriberResponse.ProtoReflect.Descriptor instead.
func (*CreateSubscriberResponse) GetSubscriberId ¶
func (x *CreateSubscriberResponse) GetSubscriberId() string
func (*CreateSubscriberResponse) ProtoMessage ¶
func (*CreateSubscriberResponse) ProtoMessage()
func (*CreateSubscriberResponse) ProtoReflect ¶
func (x *CreateSubscriberResponse) ProtoReflect() protoreflect.Message
func (*CreateSubscriberResponse) Reset ¶
func (x *CreateSubscriberResponse) Reset()
func (*CreateSubscriberResponse) String ¶
func (x *CreateSubscriberResponse) String() string
type FeedByFilterRequest ¶
type FeedByFilterRequest struct { // Deprecated: Marked as deprecated in feedpb/feed.proto. DaoId *string `protobuf:"bytes,1,opt,name=dao_id,json=daoId,proto3,oneof" json:"dao_id,omitempty"` Types []string `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"` Actions []string `protobuf:"bytes,3,rep,name=actions,proto3" json:"actions,omitempty"` Limit *uint64 `protobuf:"varint,4,opt,name=limit,proto3,oneof" json:"limit,omitempty"` Offset *uint64 `protobuf:"varint,5,opt,name=offset,proto3,oneof" json:"offset,omitempty"` DaoIds []string `protobuf:"bytes,6,rep,name=dao_ids,json=daoIds,proto3" json:"dao_ids,omitempty"` IsActive *bool `protobuf:"varint,7,opt,name=is_active,json=isActive,proto3,oneof" json:"is_active,omitempty"` // contains filtered or unexported fields }
func (*FeedByFilterRequest) Descriptor
deprecated
func (*FeedByFilterRequest) Descriptor() ([]byte, []int)
Deprecated: Use FeedByFilterRequest.ProtoReflect.Descriptor instead.
func (*FeedByFilterRequest) GetActions ¶
func (x *FeedByFilterRequest) GetActions() []string
func (*FeedByFilterRequest) GetDaoId
deprecated
func (x *FeedByFilterRequest) GetDaoId() string
Deprecated: Marked as deprecated in feedpb/feed.proto.
func (*FeedByFilterRequest) GetDaoIds ¶
func (x *FeedByFilterRequest) GetDaoIds() []string
func (*FeedByFilterRequest) GetIsActive ¶
func (x *FeedByFilterRequest) GetIsActive() bool
func (*FeedByFilterRequest) GetLimit ¶
func (x *FeedByFilterRequest) GetLimit() uint64
func (*FeedByFilterRequest) GetOffset ¶
func (x *FeedByFilterRequest) GetOffset() uint64
func (*FeedByFilterRequest) GetTypes ¶
func (x *FeedByFilterRequest) GetTypes() []string
func (*FeedByFilterRequest) ProtoMessage ¶
func (*FeedByFilterRequest) ProtoMessage()
func (*FeedByFilterRequest) ProtoReflect ¶
func (x *FeedByFilterRequest) ProtoReflect() protoreflect.Message
func (*FeedByFilterRequest) Reset ¶
func (x *FeedByFilterRequest) Reset()
func (*FeedByFilterRequest) String ¶
func (x *FeedByFilterRequest) String() string
type FeedByFilterResponse ¶
type FeedByFilterResponse struct { Items []*FeedInfo `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` TotalCount uint64 `protobuf:"varint,2,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"` // contains filtered or unexported fields }
func (*FeedByFilterResponse) Descriptor
deprecated
func (*FeedByFilterResponse) Descriptor() ([]byte, []int)
Deprecated: Use FeedByFilterResponse.ProtoReflect.Descriptor instead.
func (*FeedByFilterResponse) GetItems ¶
func (x *FeedByFilterResponse) GetItems() []*FeedInfo
func (*FeedByFilterResponse) GetTotalCount ¶
func (x *FeedByFilterResponse) GetTotalCount() uint64
func (*FeedByFilterResponse) ProtoMessage ¶
func (*FeedByFilterResponse) ProtoMessage()
func (*FeedByFilterResponse) ProtoReflect ¶
func (x *FeedByFilterResponse) ProtoReflect() protoreflect.Message
func (*FeedByFilterResponse) Reset ¶
func (x *FeedByFilterResponse) Reset()
func (*FeedByFilterResponse) String ¶
func (x *FeedByFilterResponse) String() string
type FeedClient ¶
type FeedClient interface {
GetByFilter(ctx context.Context, in *FeedByFilterRequest, opts ...grpc.CallOption) (*FeedByFilterResponse, error)
}
FeedClient is the client API for Feed service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewFeedClient ¶
func NewFeedClient(cc grpc.ClientConnInterface) FeedClient
type FeedInfo ¶
type FeedInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` DaoId string `protobuf:"bytes,4,opt,name=dao_id,json=daoId,proto3" json:"dao_id,omitempty"` ProposalId string `protobuf:"bytes,5,opt,name=proposal_id,json=proposalId,proto3" json:"proposal_id,omitempty"` DiscussionId string `protobuf:"bytes,6,opt,name=discussion_id,json=discussionId,proto3" json:"discussion_id,omitempty"` Action string `protobuf:"bytes,7,opt,name=action,proto3" json:"action,omitempty"` Snapshot *anypb.Any `protobuf:"bytes,8,opt,name=snapshot,proto3" json:"snapshot,omitempty"` Type FeedInfo_Type `protobuf:"varint,9,opt,name=type,proto3,enum=feedpb.FeedInfo_Type" json:"type,omitempty"` Timeline []*FeedTimelineItem `protobuf:"bytes,10,rep,name=timeline,proto3" json:"timeline,omitempty"` // contains filtered or unexported fields }
func (*FeedInfo) Descriptor
deprecated
func (*FeedInfo) GetCreatedAt ¶
func (x *FeedInfo) GetCreatedAt() *timestamppb.Timestamp
func (*FeedInfo) GetDiscussionId ¶
func (*FeedInfo) GetProposalId ¶
func (*FeedInfo) GetSnapshot ¶
func (*FeedInfo) GetTimeline ¶
func (x *FeedInfo) GetTimeline() []*FeedTimelineItem
func (*FeedInfo) GetType ¶
func (x *FeedInfo) GetType() FeedInfo_Type
func (*FeedInfo) GetUpdatedAt ¶
func (x *FeedInfo) GetUpdatedAt() *timestamppb.Timestamp
func (*FeedInfo) ProtoMessage ¶
func (*FeedInfo) ProtoMessage()
func (*FeedInfo) ProtoReflect ¶
func (x *FeedInfo) ProtoReflect() protoreflect.Message
type FeedInfo_Type ¶
type FeedInfo_Type int32
const ( FeedInfo_Unspecified FeedInfo_Type = 0 FeedInfo_DAO FeedInfo_Type = 1 FeedInfo_Proposal FeedInfo_Type = 2 )
func (FeedInfo_Type) Descriptor ¶
func (FeedInfo_Type) Descriptor() protoreflect.EnumDescriptor
func (FeedInfo_Type) Enum ¶
func (x FeedInfo_Type) Enum() *FeedInfo_Type
func (FeedInfo_Type) EnumDescriptor
deprecated
func (FeedInfo_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use FeedInfo_Type.Descriptor instead.
func (FeedInfo_Type) Number ¶
func (x FeedInfo_Type) Number() protoreflect.EnumNumber
func (FeedInfo_Type) String ¶
func (x FeedInfo_Type) String() string
func (FeedInfo_Type) Type ¶
func (FeedInfo_Type) Type() protoreflect.EnumType
type FeedServer ¶
type FeedServer interface { GetByFilter(context.Context, *FeedByFilterRequest) (*FeedByFilterResponse, error) // contains filtered or unexported methods }
FeedServer is the server API for Feed service. All implementations must embed UnimplementedFeedServer for forward compatibility
type FeedTimelineItem ¶
type FeedTimelineItem struct { CreatedAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` Action FeedTimelineItem_TimelineAction `protobuf:"varint,2,opt,name=action,proto3,enum=feedpb.FeedTimelineItem_TimelineAction" json:"action,omitempty"` // contains filtered or unexported fields }
func (*FeedTimelineItem) Descriptor
deprecated
func (*FeedTimelineItem) Descriptor() ([]byte, []int)
Deprecated: Use FeedTimelineItem.ProtoReflect.Descriptor instead.
func (*FeedTimelineItem) GetAction ¶
func (x *FeedTimelineItem) GetAction() FeedTimelineItem_TimelineAction
func (*FeedTimelineItem) GetCreatedAt ¶
func (x *FeedTimelineItem) GetCreatedAt() *timestamppb.Timestamp
func (*FeedTimelineItem) ProtoMessage ¶
func (*FeedTimelineItem) ProtoMessage()
func (*FeedTimelineItem) ProtoReflect ¶
func (x *FeedTimelineItem) ProtoReflect() protoreflect.Message
func (*FeedTimelineItem) Reset ¶
func (x *FeedTimelineItem) Reset()
func (*FeedTimelineItem) String ¶
func (x *FeedTimelineItem) String() string
type FeedTimelineItem_TimelineAction ¶
type FeedTimelineItem_TimelineAction int32
const ( FeedTimelineItem_Unspecified FeedTimelineItem_TimelineAction = 0 FeedTimelineItem_DaoCreated FeedTimelineItem_TimelineAction = 1 FeedTimelineItem_DaoUpdated FeedTimelineItem_TimelineAction = 2 FeedTimelineItem_ProposalCreated FeedTimelineItem_TimelineAction = 3 FeedTimelineItem_ProposalUpdated FeedTimelineItem_TimelineAction = 4 FeedTimelineItem_ProposalVotingStartsSoon FeedTimelineItem_TimelineAction = 5 FeedTimelineItem_ProposalVotingStarted FeedTimelineItem_TimelineAction = 6 FeedTimelineItem_ProposalVotingQuorumReached FeedTimelineItem_TimelineAction = 7 FeedTimelineItem_ProposalVotingEnded FeedTimelineItem_TimelineAction = 8 FeedTimelineItem_ProposalVotingEndsSoon FeedTimelineItem_TimelineAction = 9 )
func (FeedTimelineItem_TimelineAction) Descriptor ¶
func (FeedTimelineItem_TimelineAction) Descriptor() protoreflect.EnumDescriptor
func (FeedTimelineItem_TimelineAction) Enum ¶
func (x FeedTimelineItem_TimelineAction) Enum() *FeedTimelineItem_TimelineAction
func (FeedTimelineItem_TimelineAction) EnumDescriptor
deprecated
func (FeedTimelineItem_TimelineAction) EnumDescriptor() ([]byte, []int)
Deprecated: Use FeedTimelineItem_TimelineAction.Descriptor instead.
func (FeedTimelineItem_TimelineAction) Number ¶
func (x FeedTimelineItem_TimelineAction) Number() protoreflect.EnumNumber
func (FeedTimelineItem_TimelineAction) String ¶
func (x FeedTimelineItem_TimelineAction) String() string
func (FeedTimelineItem_TimelineAction) Type ¶
func (FeedTimelineItem_TimelineAction) Type() protoreflect.EnumType
type SubscribeRequest ¶
type SubscribeRequest struct { DaoId string `protobuf:"bytes,2,opt,name=dao_id,json=daoId,proto3" json:"dao_id,omitempty"` // contains filtered or unexported fields }
func (*SubscribeRequest) Descriptor
deprecated
func (*SubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeRequest) GetDaoId ¶
func (x *SubscribeRequest) GetDaoId() string
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) ProtoReflect ¶
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeRequest) Reset ¶
func (x *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶
func (x *SubscribeRequest) String() string
type SubscriberClient ¶
type SubscriberClient interface { Create(ctx context.Context, in *CreateSubscriberRequest, opts ...grpc.CallOption) (*CreateSubscriberResponse, error) Update(ctx context.Context, in *UpdateSubscriberRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
SubscriberClient is the client API for Subscriber service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSubscriberClient ¶
func NewSubscriberClient(cc grpc.ClientConnInterface) SubscriberClient
type SubscriberServer ¶
type SubscriberServer interface { Create(context.Context, *CreateSubscriberRequest) (*CreateSubscriberResponse, error) Update(context.Context, *UpdateSubscriberRequest) (*emptypb.Empty, error) // contains filtered or unexported methods }
SubscriberServer is the server API for Subscriber service. All implementations must embed UnimplementedSubscriberServer for forward compatibility
type SubscriptionClient ¶
type SubscriptionClient interface { Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
SubscriptionClient is the client API for Subscription service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSubscriptionClient ¶
func NewSubscriptionClient(cc grpc.ClientConnInterface) SubscriptionClient
type SubscriptionServer ¶
type SubscriptionServer interface { Subscribe(context.Context, *SubscribeRequest) (*emptypb.Empty, error) Unsubscribe(context.Context, *UnsubscribeRequest) (*emptypb.Empty, error) // contains filtered or unexported methods }
SubscriptionServer is the server API for Subscription service. All implementations must embed UnimplementedSubscriptionServer for forward compatibility
type UnimplementedFeedServer ¶
type UnimplementedFeedServer struct { }
UnimplementedFeedServer must be embedded to have forward compatible implementations.
func (UnimplementedFeedServer) GetByFilter ¶
func (UnimplementedFeedServer) GetByFilter(context.Context, *FeedByFilterRequest) (*FeedByFilterResponse, error)
type UnimplementedSubscriberServer ¶
type UnimplementedSubscriberServer struct { }
UnimplementedSubscriberServer must be embedded to have forward compatible implementations.
func (UnimplementedSubscriberServer) Create ¶
func (UnimplementedSubscriberServer) Create(context.Context, *CreateSubscriberRequest) (*CreateSubscriberResponse, error)
func (UnimplementedSubscriberServer) Update ¶
func (UnimplementedSubscriberServer) Update(context.Context, *UpdateSubscriberRequest) (*emptypb.Empty, error)
type UnimplementedSubscriptionServer ¶
type UnimplementedSubscriptionServer struct { }
UnimplementedSubscriptionServer must be embedded to have forward compatible implementations.
func (UnimplementedSubscriptionServer) Subscribe ¶
func (UnimplementedSubscriptionServer) Subscribe(context.Context, *SubscribeRequest) (*emptypb.Empty, error)
func (UnimplementedSubscriptionServer) Unsubscribe ¶
func (UnimplementedSubscriptionServer) Unsubscribe(context.Context, *UnsubscribeRequest) (*emptypb.Empty, error)
type UnsafeFeedServer ¶
type UnsafeFeedServer interface {
// contains filtered or unexported methods
}
UnsafeFeedServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FeedServer will result in compilation errors.
type UnsafeSubscriberServer ¶
type UnsafeSubscriberServer interface {
// contains filtered or unexported methods
}
UnsafeSubscriberServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubscriberServer will result in compilation errors.
type UnsafeSubscriptionServer ¶
type UnsafeSubscriptionServer interface {
// contains filtered or unexported methods
}
UnsafeSubscriptionServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubscriptionServer will result in compilation errors.
type UnsubscribeRequest ¶
type UnsubscribeRequest struct { DaoId string `protobuf:"bytes,2,opt,name=dao_id,json=daoId,proto3" json:"dao_id,omitempty"` // contains filtered or unexported fields }
func (*UnsubscribeRequest) Descriptor
deprecated
func (*UnsubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnsubscribeRequest.ProtoReflect.Descriptor instead.
func (*UnsubscribeRequest) GetDaoId ¶
func (x *UnsubscribeRequest) GetDaoId() string
func (*UnsubscribeRequest) ProtoMessage ¶
func (*UnsubscribeRequest) ProtoMessage()
func (*UnsubscribeRequest) ProtoReflect ¶
func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message
func (*UnsubscribeRequest) Reset ¶
func (x *UnsubscribeRequest) Reset()
func (*UnsubscribeRequest) String ¶
func (x *UnsubscribeRequest) String() string
type UpdateSubscriberRequest ¶
type UpdateSubscriberRequest struct { WebhookUrl string `protobuf:"bytes,2,opt,name=webhook_url,json=webhookUrl,proto3" json:"webhook_url,omitempty"` // contains filtered or unexported fields }
func (*UpdateSubscriberRequest) Descriptor
deprecated
func (*UpdateSubscriberRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateSubscriberRequest.ProtoReflect.Descriptor instead.
func (*UpdateSubscriberRequest) GetWebhookUrl ¶
func (x *UpdateSubscriberRequest) GetWebhookUrl() string
func (*UpdateSubscriberRequest) ProtoMessage ¶
func (*UpdateSubscriberRequest) ProtoMessage()
func (*UpdateSubscriberRequest) ProtoReflect ¶
func (x *UpdateSubscriberRequest) ProtoReflect() protoreflect.Message
func (*UpdateSubscriberRequest) Reset ¶
func (x *UpdateSubscriberRequest) Reset()
func (*UpdateSubscriberRequest) String ¶
func (x *UpdateSubscriberRequest) String() string