feedpb

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 2, 2024 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Subscriber_Create_FullMethodName = "/feedpb.Subscriber/Create"
	Subscriber_Update_FullMethodName = "/feedpb.Subscriber/Update"
)
View Source
const (
	Subscription_Subscribe_FullMethodName   = "/feedpb.Subscription/Subscribe"
	Subscription_Unsubscribe_FullMethodName = "/feedpb.Subscription/Unsubscribe"
)
View Source
const (
	Feed_GetByFilter_FullMethodName = "/feedpb.Feed/GetByFilter"
)

Variables

View Source
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.

View Source
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.

View Source
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)

View Source
var File_feedpb_feed_proto protoreflect.FileDescriptor
View Source
var File_feedpb_subscriber_proto protoreflect.FileDescriptor
View Source
var File_feedpb_subscription_proto protoreflect.FileDescriptor
View Source
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)

View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use FeedInfo.ProtoReflect.Descriptor instead.

func (*FeedInfo) GetAction

func (x *FeedInfo) GetAction() string

func (*FeedInfo) GetCreatedAt

func (x *FeedInfo) GetCreatedAt() *timestamppb.Timestamp

func (*FeedInfo) GetDaoId

func (x *FeedInfo) GetDaoId() string

func (*FeedInfo) GetDiscussionId

func (x *FeedInfo) GetDiscussionId() string

func (*FeedInfo) GetId

func (x *FeedInfo) GetId() string

func (*FeedInfo) GetProposalId

func (x *FeedInfo) GetProposalId() string

func (*FeedInfo) GetSnapshot

func (x *FeedInfo) GetSnapshot() *anypb.Any

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

func (*FeedInfo) Reset

func (x *FeedInfo) Reset()

func (*FeedInfo) String

func (x *FeedInfo) String() string

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) 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 (FeedInfo_Type) String

func (x FeedInfo_Type) String() string

func (FeedInfo_Type) Type

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 (*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) Enum

func (FeedTimelineItem_TimelineAction) EnumDescriptor deprecated

func (FeedTimelineItem_TimelineAction) EnumDescriptor() ([]byte, []int)

Deprecated: Use FeedTimelineItem_TimelineAction.Descriptor instead.

func (FeedTimelineItem_TimelineAction) Number

func (FeedTimelineItem_TimelineAction) String

func (FeedTimelineItem_TimelineAction) Type

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.

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

type UnimplementedSubscriberServer

type UnimplementedSubscriberServer struct {
}

UnimplementedSubscriberServer must be embedded to have forward compatible implementations.

func (UnimplementedSubscriberServer) Update

type UnimplementedSubscriptionServer

type UnimplementedSubscriptionServer struct {
}

UnimplementedSubscriptionServer must be embedded to have forward compatible implementations.

func (UnimplementedSubscriptionServer) Subscribe

func (UnimplementedSubscriptionServer) Unsubscribe

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL