pb

type AddAnnouncementRequest struct {

	// A UUID string identifying an annoucement graph vertex.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type AddContentRequest struct {

	// Type of content pointed at by
	ContentType ContentType `` /* 126-byte string literal not displayed */
	// A UUID string identifying the graph vertex
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// Minimum amount of time to wait between appearences in the feed.
	Wait *durationpb.Duration `protobuf:"bytes,3,opt,name=wait,proto3" json:"wait,omitempty"`
	// If specified, content should be promoted starting now until this time.
	Until *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=until,proto3" json:"until,omitempty"`
	// If specified, content should not be promoted at all after this date.
	Expires *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expires,proto3" json:"expires,omitempty"`
	// If specified, schedule this item to publish immediately.
	ImmediateRelease bool `protobuf:"varint,6,opt,name=ImmediateRelease,proto3" json:"ImmediateRelease,omitempty"`
	// contains filtered or unexported fields
}

type ContentItem struct {

	// The ID of this entry in the feed. Any given content ID can be inserted
	// into the feed multiple time, this ID identifies each insertion uniquely.
	FeedId string `protobuf:"bytes,1,opt,name=feed_id,json=feedId,proto3" json:"feed_id,omitempty"`
	// The UUID of the graph vertex of the content inserted here.
	ContentId string `protobuf:"bytes,2,opt,name=content_id,json=contentId,proto3" json:"content_id,omitempty"`
	// Timestamp indicated when this content item was inserted in the feed.
	AddedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=added_at,json=addedAt,proto3" json:"added_at,omitempty"`
	// contains filtered or unexported fields
}

type ContentType int32

type FeedProducerClient interface {
	// AddAnnouncement is the method used to provided announcement to Feed Producer.
	AddAnnouncement(ctx context.Context, in *AddAnnouncementRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// AddContent is the method used to provide content items to Feed Producer.
	AddContent(ctx context.Context, in *AddContentRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// RemoveContent is the method used to tell Feed Producer to forget an item.
	RemoveContent(ctx context.Context, in *RemoveContentRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ReadLatest returns the latest items from the feed.
	ReadLatest(ctx context.Context, in *ReadLatestRequest, opts ...grpc.CallOption) (*ReadLatestResponse, error)
	// ListActiveReleases returns a list of active releases only.
	ListActiveReleases(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (FeedProducer_ListActiveReleasesClient, error)
	// ListAllReleases returns a list of every release, active and waiting.
	ListAllReleases(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (FeedProducer_ListAllReleasesClient, error)
	// QueueItem schedules an item for immediate release.
	QueueItem(ctx context.Context, in *QueueItemRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type FeedProducerServer interface {
	// AddAnnouncement is the method used to provided announcement to Feed Producer.
	AddAnnouncement(context.Context, *AddAnnouncementRequest) (*emptypb.Empty, error)
	// AddContent is the method used to provide content items to Feed Producer.
	AddContent(context.Context, *AddContentRequest) (*emptypb.Empty, error)
	// RemoveContent is the method used to tell Feed Producer to forget an item.
	RemoveContent(context.Context, *RemoveContentRequest) (*emptypb.Empty, error)
	// ReadLatest returns the latest items from the feed.
	ReadLatest(context.Context, *ReadLatestRequest) (*ReadLatestResponse, error)
	// ListActiveReleases returns a list of active releases only.
	ListActiveReleases(*emptypb.Empty, FeedProducer_ListActiveReleasesServer) error
	// ListAllReleases returns a list of every release, active and waiting.
	ListAllReleases(*emptypb.Empty, FeedProducer_ListAllReleasesServer) error
	// QueueItem schedules an item for immediate release.
	QueueItem(context.Context, *QueueItemRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type FeedProducer_ListActiveReleasesClient interface {
	Recv() (*ReleaseItem, error)
	grpc.ClientStream
}

type FeedProducer_ListActiveReleasesServer interface {
	Send(*ReleaseItem) error
	grpc.ServerStream
}

type FeedProducer_ListAllReleasesClient interface {
	Recv() (*ReleaseItem, error)
	grpc.ClientStream
}

type FeedProducer_ListAllReleasesServer interface {
	Send(*ReleaseItem) error
	grpc.ServerStream
}

type QueueItemRequest struct {

	// A UUID string identifying the graph vertex
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type ReadLatestRequest struct {

	// Number of ContentItem messages to return.
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type ReadLatestResponse struct {

	// Latest ContentItem messages from the feed.
	Latest []*ContentItem `protobuf:"bytes,1,rep,name=latest,proto3" json:"latest,omitempty"`
	// contains filtered or unexported fields
}

type ReleaseItem struct {

	// The UUID of the graph vertex of the content to be released.
	ContentId string `protobuf:"bytes,1,opt,name=content_id,json=contentId,proto3" json:"content_id,omitempty"`
	// The type of this vertex in Citygraph.
	VertexType string `protobuf:"bytes,2,opt,name=vertex_type,json=vertexType,proto3" json:"vertex_type,omitempty"`
	// contains filtered or unexported fields
}

type RemoveContentRequest struct {

	// A UUID string identifying the graph vertex to remove.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedFeedProducerServer struct {
}

type UnsafeFeedProducerServer interface {
	// contains filtered or unexported methods
}