// Code generated by protoc-gen-go-grpc. DO NOT EDIT.

package golang_client

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7

// TimelineManagerClient is the client API for TimelineManager 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 TimelineManagerClient interface {
	// GetAll (Server Stream)
	GetAll(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (TimelineManager_GetAllClient, error)
	// GetEmptyTimeline (Unary)
	GetEmptyTimeline(ctx context.Context, in *GetEmptyTimelineRequest, opts ...grpc.CallOption) (*GetEmptyTimelineResponse, error)
	// GetById (Unary)
	GetById(ctx context.Context, in *GetByIdRequest, opts ...grpc.CallOption) (*GetByIdResponse, error)
	// GetByIds (Unary)
	GetByIds(ctx context.Context, in *GetByIdsRequest, opts ...grpc.CallOption) (*GetByIdsResponse, error)
	// GetByEpisodeId (Unary)
	GetByEpisodeId(ctx context.Context, in *GetByEpisodeIdRequest, opts ...grpc.CallOption) (*GetByEpisodeIdResponse, error)
	// GetDocumentsUpdatedBetweenDatesOnChannel (Server Stream)
	GetDocumentsUpdatedBetweenDatesOnChannel(ctx context.Context, in *GetDocumentsUpdatedBetweenDatesOnChannelRequest, opts ...grpc.CallOption) (TimelineManager_GetDocumentsUpdatedBetweenDatesOnChannelClient, error)
	// GetDocumentsUpdatedBetweenDates (Server Stream)
	// Returns documents greater than start_min and less then start_max
	GetDocumentsBetweenDates(ctx context.Context, in *GetDocumentsBetweenDatesRequest, opts ...grpc.CallOption) (TimelineManager_GetDocumentsBetweenDatesClient, error)
	// CFeedsSyncDocuments (Server Stream)
	CFeedsSyncDocuments(ctx context.Context, in *CFeedsSyncDocumentsRequest, opts ...grpc.CallOption) (TimelineManager_CFeedsSyncDocumentsClient, error)
	// CFeedsSyncAllIds (Server Stream)
	CFeedsSyncAllIds(ctx context.Context, in *CFeedsSyncAllIdsRequest, opts ...grpc.CallOption) (TimelineManager_CFeedsSyncAllIdsClient, error)
	// GetTimelineById (Unary)
	//
	// Deprecated.Will be removed once client (FW IVI) no longer using
	GetTimelineById(ctx context.Context, in *GetTimelineByIdRequest, opts ...grpc.CallOption) (*GetTimelineByIdResponse, error)
	// GetOne (Unary)
	GetOne(ctx context.Context, in *GetOneRequest, opts ...grpc.CallOption) (*GetOneResponse, error)
	// DeleteById (Unary)
	DeleteById(ctx context.Context, in *DeleteByIdRequest, opts ...grpc.CallOption) (*DeleteByIdResponse, error)
	Count(ctx context.Context, in *GetCountRequest, opts ...grpc.CallOption) (*GetCountResponse, error)
	GetTimelinesForAutoSchedule(ctx context.Context, in *GetTimelinesForAutoScheduleRequest, opts ...grpc.CallOption) (*GetTimelinesForAutoScheduleResponse, error)
	GetTimelinesForRepeatSchedule(ctx context.Context, in *GetTimelinesForRepeatScheduleRequest, opts ...grpc.CallOption) (*GetTimelinesForRepeatScheduleResponse, error)
	UpdateTimelinesBulk(ctx context.Context, in *UpdateTimelinesBulkRequest, opts ...grpc.CallOption) (*UpdateTimelinesBulkResponse, error)
	GetPopulatedTimelinesByChannelId(ctx context.Context, in *GetPopulatedTimelinesByChannelIdRequest, opts ...grpc.CallOption) (*GetPopulatedTimelinesByChannelIdResponse, error)
	DeleteTimelinesInChannelByDates(ctx context.Context, in *DeleteTimelinesInChannelByDatesRequest, opts ...grpc.CallOption) (*DeleteTimelinesInChannelByDatesResponse, error)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	GetTimelinesByChannelId(ctx context.Context, in *GetTimelinesByChannelIdRequest, opts ...grpc.CallOption) (*GetTimelinesByChannelIdResponse, error)
	GetTimelineIdsByClipId(ctx context.Context, in *GetTimelineIdsByClipIdRequest, opts ...grpc.CallOption) (*GetTimelineIdsByClipIdResponse, error)
	GetTimelinesLiteByChannelId(ctx context.Context, in *GetTimelinesLiteByChannelIdRequest, opts ...grpc.CallOption) (*GetTimelinesLiteByChannelIdResponse, error)
	// GetDocumentsBetweenStartDates (Server Stream)
	GetDocumentsBetweenStartDates(ctx context.Context, in *GetDocumentsBetweenStartDatesRequest, opts ...grpc.CallOption) (TimelineManager_GetDocumentsBetweenStartDatesClient, error)
	// AggregateByEpisodes (Unary)
	AggregateByEpisodes(ctx context.Context, in *AggregateByEpisodesRequest, opts ...grpc.CallOption) (*AggregateByEpisodesResponse, error)
	// GetAllBy (Unary)
	GetAllBy(ctx context.Context, in *GetAllByRequest, opts ...grpc.CallOption) (*GetAllByResponse, error)
}

type timelineManagerClient struct {
	cc grpc.ClientConnInterface
}

func NewTimelineManagerClient(cc grpc.ClientConnInterface) TimelineManagerClient {
	return &timelineManagerClient{cc}
}

func (c *timelineManagerClient) GetAll(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (TimelineManager_GetAllClient, error) {
	stream, err := c.cc.NewStream(ctx, &TimelineManager_ServiceDesc.Streams[0], "/timelinepackage.TimelineManager/GetAll", opts...)
	if err != nil {
		return nil, err
	}
	x := &timelineManagerGetAllClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type TimelineManager_GetAllClient interface {
	Recv() (*Timeline, error)
	grpc.ClientStream
}

type timelineManagerGetAllClient struct {
	grpc.ClientStream
}

func (x *timelineManagerGetAllClient) Recv() (*Timeline, error) {
	m := new(Timeline)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *timelineManagerClient) GetEmptyTimeline(ctx context.Context, in *GetEmptyTimelineRequest, opts ...grpc.CallOption) (*GetEmptyTimelineResponse, error) {
	out := new(GetEmptyTimelineResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetEmptyTimeline", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetById(ctx context.Context, in *GetByIdRequest, opts ...grpc.CallOption) (*GetByIdResponse, error) {
	out := new(GetByIdResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetByIds(ctx context.Context, in *GetByIdsRequest, opts ...grpc.CallOption) (*GetByIdsResponse, error) {
	out := new(GetByIdsResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetByIds", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetByEpisodeId(ctx context.Context, in *GetByEpisodeIdRequest, opts ...grpc.CallOption) (*GetByEpisodeIdResponse, error) {
	out := new(GetByEpisodeIdResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetByEpisodeId", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetDocumentsUpdatedBetweenDatesOnChannel(ctx context.Context, in *GetDocumentsUpdatedBetweenDatesOnChannelRequest, opts ...grpc.CallOption) (TimelineManager_GetDocumentsUpdatedBetweenDatesOnChannelClient, error) {
	stream, err := c.cc.NewStream(ctx, &TimelineManager_ServiceDesc.Streams[1], "/timelinepackage.TimelineManager/GetDocumentsUpdatedBetweenDatesOnChannel", opts...)
	if err != nil {
		return nil, err
	}
	x := &timelineManagerGetDocumentsUpdatedBetweenDatesOnChannelClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type TimelineManager_GetDocumentsUpdatedBetweenDatesOnChannelClient interface {
	Recv() (*Timeline, error)
	grpc.ClientStream
}

type timelineManagerGetDocumentsUpdatedBetweenDatesOnChannelClient struct {
	grpc.ClientStream
}

func (x *timelineManagerGetDocumentsUpdatedBetweenDatesOnChannelClient) Recv() (*Timeline, error) {
	m := new(Timeline)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *timelineManagerClient) GetDocumentsBetweenDates(ctx context.Context, in *GetDocumentsBetweenDatesRequest, opts ...grpc.CallOption) (TimelineManager_GetDocumentsBetweenDatesClient, error) {
	stream, err := c.cc.NewStream(ctx, &TimelineManager_ServiceDesc.Streams[2], "/timelinepackage.TimelineManager/GetDocumentsBetweenDates", opts...)
	if err != nil {
		return nil, err
	}
	x := &timelineManagerGetDocumentsBetweenDatesClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type TimelineManager_GetDocumentsBetweenDatesClient interface {
	Recv() (*Timeline, error)
	grpc.ClientStream
}

type timelineManagerGetDocumentsBetweenDatesClient struct {
	grpc.ClientStream
}

func (x *timelineManagerGetDocumentsBetweenDatesClient) Recv() (*Timeline, error) {
	m := new(Timeline)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *timelineManagerClient) CFeedsSyncDocuments(ctx context.Context, in *CFeedsSyncDocumentsRequest, opts ...grpc.CallOption) (TimelineManager_CFeedsSyncDocumentsClient, error) {
	stream, err := c.cc.NewStream(ctx, &TimelineManager_ServiceDesc.Streams[3], "/timelinepackage.TimelineManager/CFeedsSyncDocuments", opts...)
	if err != nil {
		return nil, err
	}
	x := &timelineManagerCFeedsSyncDocumentsClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type TimelineManager_CFeedsSyncDocumentsClient interface {
	Recv() (*Timeline, error)
	grpc.ClientStream
}

type timelineManagerCFeedsSyncDocumentsClient struct {
	grpc.ClientStream
}

func (x *timelineManagerCFeedsSyncDocumentsClient) Recv() (*Timeline, error) {
	m := new(Timeline)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *timelineManagerClient) CFeedsSyncAllIds(ctx context.Context, in *CFeedsSyncAllIdsRequest, opts ...grpc.CallOption) (TimelineManager_CFeedsSyncAllIdsClient, error) {
	stream, err := c.cc.NewStream(ctx, &TimelineManager_ServiceDesc.Streams[4], "/timelinepackage.TimelineManager/CFeedsSyncAllIds", opts...)
	if err != nil {
		return nil, err
	}
	x := &timelineManagerCFeedsSyncAllIdsClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type TimelineManager_CFeedsSyncAllIdsClient interface {
	Recv() (*Id, error)
	grpc.ClientStream
}

type timelineManagerCFeedsSyncAllIdsClient struct {
	grpc.ClientStream
}

func (x *timelineManagerCFeedsSyncAllIdsClient) Recv() (*Id, error) {
	m := new(Id)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *timelineManagerClient) GetTimelineById(ctx context.Context, in *GetTimelineByIdRequest, opts ...grpc.CallOption) (*GetTimelineByIdResponse, error) {
	out := new(GetTimelineByIdResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetTimelineById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetOne(ctx context.Context, in *GetOneRequest, opts ...grpc.CallOption) (*GetOneResponse, error) {
	out := new(GetOneResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetOne", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) DeleteById(ctx context.Context, in *DeleteByIdRequest, opts ...grpc.CallOption) (*DeleteByIdResponse, error) {
	out := new(DeleteByIdResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/DeleteById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) Count(ctx context.Context, in *GetCountRequest, opts ...grpc.CallOption) (*GetCountResponse, error) {
	out := new(GetCountResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/Count", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetTimelinesForAutoSchedule(ctx context.Context, in *GetTimelinesForAutoScheduleRequest, opts ...grpc.CallOption) (*GetTimelinesForAutoScheduleResponse, error) {
	out := new(GetTimelinesForAutoScheduleResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetTimelinesForAutoSchedule", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetTimelinesForRepeatSchedule(ctx context.Context, in *GetTimelinesForRepeatScheduleRequest, opts ...grpc.CallOption) (*GetTimelinesForRepeatScheduleResponse, error) {
	out := new(GetTimelinesForRepeatScheduleResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetTimelinesForRepeatSchedule", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) UpdateTimelinesBulk(ctx context.Context, in *UpdateTimelinesBulkRequest, opts ...grpc.CallOption) (*UpdateTimelinesBulkResponse, error) {
	out := new(UpdateTimelinesBulkResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/UpdateTimelinesBulk", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetPopulatedTimelinesByChannelId(ctx context.Context, in *GetPopulatedTimelinesByChannelIdRequest, opts ...grpc.CallOption) (*GetPopulatedTimelinesByChannelIdResponse, error) {
	out := new(GetPopulatedTimelinesByChannelIdResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetPopulatedTimelinesByChannelId", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) DeleteTimelinesInChannelByDates(ctx context.Context, in *DeleteTimelinesInChannelByDatesRequest, opts ...grpc.CallOption) (*DeleteTimelinesInChannelByDatesResponse, error) {
	out := new(DeleteTimelinesInChannelByDatesResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/DeleteTimelinesInChannelByDates", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
	out := new(CreateResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/Create", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetTimelinesByChannelId(ctx context.Context, in *GetTimelinesByChannelIdRequest, opts ...grpc.CallOption) (*GetTimelinesByChannelIdResponse, error) {
	out := new(GetTimelinesByChannelIdResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetTimelinesByChannelId", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetTimelineIdsByClipId(ctx context.Context, in *GetTimelineIdsByClipIdRequest, opts ...grpc.CallOption) (*GetTimelineIdsByClipIdResponse, error) {
	out := new(GetTimelineIdsByClipIdResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetTimelineIdsByClipId", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetTimelinesLiteByChannelId(ctx context.Context, in *GetTimelinesLiteByChannelIdRequest, opts ...grpc.CallOption) (*GetTimelinesLiteByChannelIdResponse, error) {
	out := new(GetTimelinesLiteByChannelIdResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetTimelinesLiteByChannelId", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetDocumentsBetweenStartDates(ctx context.Context, in *GetDocumentsBetweenStartDatesRequest, opts ...grpc.CallOption) (TimelineManager_GetDocumentsBetweenStartDatesClient, error) {
	stream, err := c.cc.NewStream(ctx, &TimelineManager_ServiceDesc.Streams[5], "/timelinepackage.TimelineManager/GetDocumentsBetweenStartDates", opts...)
	if err != nil {
		return nil, err
	}
	x := &timelineManagerGetDocumentsBetweenStartDatesClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type TimelineManager_GetDocumentsBetweenStartDatesClient interface {
	Recv() (*Timeline, error)
	grpc.ClientStream
}

type timelineManagerGetDocumentsBetweenStartDatesClient struct {
	grpc.ClientStream
}

func (x *timelineManagerGetDocumentsBetweenStartDatesClient) Recv() (*Timeline, error) {
	m := new(Timeline)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *timelineManagerClient) AggregateByEpisodes(ctx context.Context, in *AggregateByEpisodesRequest, opts ...grpc.CallOption) (*AggregateByEpisodesResponse, error) {
	out := new(AggregateByEpisodesResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/AggregateByEpisodes", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *timelineManagerClient) GetAllBy(ctx context.Context, in *GetAllByRequest, opts ...grpc.CallOption) (*GetAllByResponse, error) {
	out := new(GetAllByResponse)
	err := c.cc.Invoke(ctx, "/timelinepackage.TimelineManager/GetAllBy", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// TimelineManagerServer is the server API for TimelineManager service.
// All implementations must embed UnimplementedTimelineManagerServer
// for forward compatibility
type TimelineManagerServer interface {
	// GetAll (Server Stream)
	GetAll(*GetAllRequest, TimelineManager_GetAllServer) error
	// GetEmptyTimeline (Unary)
	GetEmptyTimeline(context.Context, *GetEmptyTimelineRequest) (*GetEmptyTimelineResponse, error)
	// GetById (Unary)
	GetById(context.Context, *GetByIdRequest) (*GetByIdResponse, error)
	// GetByIds (Unary)
	GetByIds(context.Context, *GetByIdsRequest) (*GetByIdsResponse, error)
	// GetByEpisodeId (Unary)
	GetByEpisodeId(context.Context, *GetByEpisodeIdRequest) (*GetByEpisodeIdResponse, error)
	// GetDocumentsUpdatedBetweenDatesOnChannel (Server Stream)
	GetDocumentsUpdatedBetweenDatesOnChannel(*GetDocumentsUpdatedBetweenDatesOnChannelRequest, TimelineManager_GetDocumentsUpdatedBetweenDatesOnChannelServer) error
	// GetDocumentsUpdatedBetweenDates (Server Stream)
	// Returns documents greater than start_min and less then start_max
	GetDocumentsBetweenDates(*GetDocumentsBetweenDatesRequest, TimelineManager_GetDocumentsBetweenDatesServer) error
	// CFeedsSyncDocuments (Server Stream)
	CFeedsSyncDocuments(*CFeedsSyncDocumentsRequest, TimelineManager_CFeedsSyncDocumentsServer) error
	// CFeedsSyncAllIds (Server Stream)
	CFeedsSyncAllIds(*CFeedsSyncAllIdsRequest, TimelineManager_CFeedsSyncAllIdsServer) error
	// GetTimelineById (Unary)
	//
	// Deprecated.Will be removed once client (FW IVI) no longer using
	GetTimelineById(context.Context, *GetTimelineByIdRequest) (*GetTimelineByIdResponse, error)
	// GetOne (Unary)
	GetOne(context.Context, *GetOneRequest) (*GetOneResponse, error)
	// DeleteById (Unary)
	DeleteById(context.Context, *DeleteByIdRequest) (*DeleteByIdResponse, error)
	Count(context.Context, *GetCountRequest) (*GetCountResponse, error)
	GetTimelinesForAutoSchedule(context.Context, *GetTimelinesForAutoScheduleRequest) (*GetTimelinesForAutoScheduleResponse, error)
	GetTimelinesForRepeatSchedule(context.Context, *GetTimelinesForRepeatScheduleRequest) (*GetTimelinesForRepeatScheduleResponse, error)
	UpdateTimelinesBulk(context.Context, *UpdateTimelinesBulkRequest) (*UpdateTimelinesBulkResponse, error)
	GetPopulatedTimelinesByChannelId(context.Context, *GetPopulatedTimelinesByChannelIdRequest) (*GetPopulatedTimelinesByChannelIdResponse, error)
	DeleteTimelinesInChannelByDates(context.Context, *DeleteTimelinesInChannelByDatesRequest) (*DeleteTimelinesInChannelByDatesResponse, error)
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	GetTimelinesByChannelId(context.Context, *GetTimelinesByChannelIdRequest) (*GetTimelinesByChannelIdResponse, error)
	GetTimelineIdsByClipId(context.Context, *GetTimelineIdsByClipIdRequest) (*GetTimelineIdsByClipIdResponse, error)
	GetTimelinesLiteByChannelId(context.Context, *GetTimelinesLiteByChannelIdRequest) (*GetTimelinesLiteByChannelIdResponse, error)
	// GetDocumentsBetweenStartDates (Server Stream)
	GetDocumentsBetweenStartDates(*GetDocumentsBetweenStartDatesRequest, TimelineManager_GetDocumentsBetweenStartDatesServer) error
	// AggregateByEpisodes (Unary)
	AggregateByEpisodes(context.Context, *AggregateByEpisodesRequest) (*AggregateByEpisodesResponse, error)
	// GetAllBy (Unary)
	GetAllBy(context.Context, *GetAllByRequest) (*GetAllByResponse, error)
	mustEmbedUnimplementedTimelineManagerServer()
}

// UnimplementedTimelineManagerServer must be embedded to have forward compatible implementations.
type UnimplementedTimelineManagerServer struct {
}

func (UnimplementedTimelineManagerServer) GetAll(*GetAllRequest, TimelineManager_GetAllServer) error {
	return status.Errorf(codes.Unimplemented, "method GetAll not implemented")
}
func (UnimplementedTimelineManagerServer) GetEmptyTimeline(context.Context, *GetEmptyTimelineRequest) (*GetEmptyTimelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetEmptyTimeline not implemented")
}
func (UnimplementedTimelineManagerServer) GetById(context.Context, *GetByIdRequest) (*GetByIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetById not implemented")
}
func (UnimplementedTimelineManagerServer) GetByIds(context.Context, *GetByIdsRequest) (*GetByIdsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetByIds not implemented")
}
func (UnimplementedTimelineManagerServer) GetByEpisodeId(context.Context, *GetByEpisodeIdRequest) (*GetByEpisodeIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetByEpisodeId not implemented")
}
func (UnimplementedTimelineManagerServer) GetDocumentsUpdatedBetweenDatesOnChannel(*GetDocumentsUpdatedBetweenDatesOnChannelRequest, TimelineManager_GetDocumentsUpdatedBetweenDatesOnChannelServer) error {
	return status.Errorf(codes.Unimplemented, "method GetDocumentsUpdatedBetweenDatesOnChannel not implemented")
}
func (UnimplementedTimelineManagerServer) GetDocumentsBetweenDates(*GetDocumentsBetweenDatesRequest, TimelineManager_GetDocumentsBetweenDatesServer) error {
	return status.Errorf(codes.Unimplemented, "method GetDocumentsBetweenDates not implemented")
}
func (UnimplementedTimelineManagerServer) CFeedsSyncDocuments(*CFeedsSyncDocumentsRequest, TimelineManager_CFeedsSyncDocumentsServer) error {
	return status.Errorf(codes.Unimplemented, "method CFeedsSyncDocuments not implemented")
}
func (UnimplementedTimelineManagerServer) CFeedsSyncAllIds(*CFeedsSyncAllIdsRequest, TimelineManager_CFeedsSyncAllIdsServer) error {
	return status.Errorf(codes.Unimplemented, "method CFeedsSyncAllIds not implemented")
}
func (UnimplementedTimelineManagerServer) GetTimelineById(context.Context, *GetTimelineByIdRequest) (*GetTimelineByIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetTimelineById not implemented")
}
func (UnimplementedTimelineManagerServer) GetOne(context.Context, *GetOneRequest) (*GetOneResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetOne not implemented")
}
func (UnimplementedTimelineManagerServer) DeleteById(context.Context, *DeleteByIdRequest) (*DeleteByIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteById not implemented")
}
func (UnimplementedTimelineManagerServer) Count(context.Context, *GetCountRequest) (*GetCountResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Count not implemented")
}
func (UnimplementedTimelineManagerServer) GetTimelinesForAutoSchedule(context.Context, *GetTimelinesForAutoScheduleRequest) (*GetTimelinesForAutoScheduleResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetTimelinesForAutoSchedule not implemented")
}
func (UnimplementedTimelineManagerServer) GetTimelinesForRepeatSchedule(context.Context, *GetTimelinesForRepeatScheduleRequest) (*GetTimelinesForRepeatScheduleResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetTimelinesForRepeatSchedule not implemented")
}
func (UnimplementedTimelineManagerServer) UpdateTimelinesBulk(context.Context, *UpdateTimelinesBulkRequest) (*UpdateTimelinesBulkResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateTimelinesBulk not implemented")
}
func (UnimplementedTimelineManagerServer) GetPopulatedTimelinesByChannelId(context.Context, *GetPopulatedTimelinesByChannelIdRequest) (*GetPopulatedTimelinesByChannelIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPopulatedTimelinesByChannelId not implemented")
}
func (UnimplementedTimelineManagerServer) DeleteTimelinesInChannelByDates(context.Context, *DeleteTimelinesInChannelByDatesRequest) (*DeleteTimelinesInChannelByDatesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteTimelinesInChannelByDates not implemented")
}
func (UnimplementedTimelineManagerServer) Create(context.Context, *CreateRequest) (*CreateResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Create not implemented")
}
func (UnimplementedTimelineManagerServer) GetTimelinesByChannelId(context.Context, *GetTimelinesByChannelIdRequest) (*GetTimelinesByChannelIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetTimelinesByChannelId not implemented")
}
func (UnimplementedTimelineManagerServer) GetTimelineIdsByClipId(context.Context, *GetTimelineIdsByClipIdRequest) (*GetTimelineIdsByClipIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetTimelineIdsByClipId not implemented")
}
func (UnimplementedTimelineManagerServer) GetTimelinesLiteByChannelId(context.Context, *GetTimelinesLiteByChannelIdRequest) (*GetTimelinesLiteByChannelIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetTimelinesLiteByChannelId not implemented")
}
func (UnimplementedTimelineManagerServer) GetDocumentsBetweenStartDates(*GetDocumentsBetweenStartDatesRequest, TimelineManager_GetDocumentsBetweenStartDatesServer) error {
	return status.Errorf(codes.Unimplemented, "method GetDocumentsBetweenStartDates not implemented")
}
func (UnimplementedTimelineManagerServer) AggregateByEpisodes(context.Context, *AggregateByEpisodesRequest) (*AggregateByEpisodesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method AggregateByEpisodes not implemented")
}
func (UnimplementedTimelineManagerServer) GetAllBy(context.Context, *GetAllByRequest) (*GetAllByResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetAllBy not implemented")
}
func (UnimplementedTimelineManagerServer) mustEmbedUnimplementedTimelineManagerServer() {}

// UnsafeTimelineManagerServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to TimelineManagerServer will
// result in compilation errors.
type UnsafeTimelineManagerServer interface {
	mustEmbedUnimplementedTimelineManagerServer()
}

func RegisterTimelineManagerServer(s grpc.ServiceRegistrar, srv TimelineManagerServer) {
	s.RegisterService(&TimelineManager_ServiceDesc, srv)
}

func _TimelineManager_GetAll_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(GetAllRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(TimelineManagerServer).GetAll(m, &timelineManagerGetAllServer{stream})
}

type TimelineManager_GetAllServer interface {
	Send(*Timeline) error
	grpc.ServerStream
}

type timelineManagerGetAllServer struct {
	grpc.ServerStream
}

func (x *timelineManagerGetAllServer) Send(m *Timeline) error {
	return x.ServerStream.SendMsg(m)
}

func _TimelineManager_GetEmptyTimeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetEmptyTimelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetEmptyTimeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetEmptyTimeline",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetEmptyTimeline(ctx, req.(*GetEmptyTimelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetByIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetById(ctx, req.(*GetByIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetByIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetByIdsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetByIds(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetByIds",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetByIds(ctx, req.(*GetByIdsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetByEpisodeId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetByEpisodeIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetByEpisodeId(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetByEpisodeId",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetByEpisodeId(ctx, req.(*GetByEpisodeIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetDocumentsUpdatedBetweenDatesOnChannel_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(GetDocumentsUpdatedBetweenDatesOnChannelRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(TimelineManagerServer).GetDocumentsUpdatedBetweenDatesOnChannel(m, &timelineManagerGetDocumentsUpdatedBetweenDatesOnChannelServer{stream})
}

type TimelineManager_GetDocumentsUpdatedBetweenDatesOnChannelServer interface {
	Send(*Timeline) error
	grpc.ServerStream
}

type timelineManagerGetDocumentsUpdatedBetweenDatesOnChannelServer struct {
	grpc.ServerStream
}

func (x *timelineManagerGetDocumentsUpdatedBetweenDatesOnChannelServer) Send(m *Timeline) error {
	return x.ServerStream.SendMsg(m)
}

func _TimelineManager_GetDocumentsBetweenDates_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(GetDocumentsBetweenDatesRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(TimelineManagerServer).GetDocumentsBetweenDates(m, &timelineManagerGetDocumentsBetweenDatesServer{stream})
}

type TimelineManager_GetDocumentsBetweenDatesServer interface {
	Send(*Timeline) error
	grpc.ServerStream
}

type timelineManagerGetDocumentsBetweenDatesServer struct {
	grpc.ServerStream
}

func (x *timelineManagerGetDocumentsBetweenDatesServer) Send(m *Timeline) error {
	return x.ServerStream.SendMsg(m)
}

func _TimelineManager_CFeedsSyncDocuments_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(CFeedsSyncDocumentsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(TimelineManagerServer).CFeedsSyncDocuments(m, &timelineManagerCFeedsSyncDocumentsServer{stream})
}

type TimelineManager_CFeedsSyncDocumentsServer interface {
	Send(*Timeline) error
	grpc.ServerStream
}

type timelineManagerCFeedsSyncDocumentsServer struct {
	grpc.ServerStream
}

func (x *timelineManagerCFeedsSyncDocumentsServer) Send(m *Timeline) error {
	return x.ServerStream.SendMsg(m)
}

func _TimelineManager_CFeedsSyncAllIds_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(CFeedsSyncAllIdsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(TimelineManagerServer).CFeedsSyncAllIds(m, &timelineManagerCFeedsSyncAllIdsServer{stream})
}

type TimelineManager_CFeedsSyncAllIdsServer interface {
	Send(*Id) error
	grpc.ServerStream
}

type timelineManagerCFeedsSyncAllIdsServer struct {
	grpc.ServerStream
}

func (x *timelineManagerCFeedsSyncAllIdsServer) Send(m *Id) error {
	return x.ServerStream.SendMsg(m)
}

func _TimelineManager_GetTimelineById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetTimelineByIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetTimelineById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetTimelineById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetTimelineById(ctx, req.(*GetTimelineByIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetOne_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetOneRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetOne(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetOne",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetOne(ctx, req.(*GetOneRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_DeleteById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteByIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).DeleteById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/DeleteById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).DeleteById(ctx, req.(*DeleteByIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_Count_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetCountRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).Count(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/Count",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).Count(ctx, req.(*GetCountRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetTimelinesForAutoSchedule_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetTimelinesForAutoScheduleRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetTimelinesForAutoSchedule(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetTimelinesForAutoSchedule",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetTimelinesForAutoSchedule(ctx, req.(*GetTimelinesForAutoScheduleRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetTimelinesForRepeatSchedule_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetTimelinesForRepeatScheduleRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetTimelinesForRepeatSchedule(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetTimelinesForRepeatSchedule",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetTimelinesForRepeatSchedule(ctx, req.(*GetTimelinesForRepeatScheduleRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_UpdateTimelinesBulk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateTimelinesBulkRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).UpdateTimelinesBulk(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/UpdateTimelinesBulk",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).UpdateTimelinesBulk(ctx, req.(*UpdateTimelinesBulkRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetPopulatedTimelinesByChannelId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPopulatedTimelinesByChannelIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetPopulatedTimelinesByChannelId(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetPopulatedTimelinesByChannelId",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetPopulatedTimelinesByChannelId(ctx, req.(*GetPopulatedTimelinesByChannelIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_DeleteTimelinesInChannelByDates_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteTimelinesInChannelByDatesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).DeleteTimelinesInChannelByDates(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/DeleteTimelinesInChannelByDates",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).DeleteTimelinesInChannelByDates(ctx, req.(*DeleteTimelinesInChannelByDatesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).Create(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/Create",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).Create(ctx, req.(*CreateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetTimelinesByChannelId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetTimelinesByChannelIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetTimelinesByChannelId(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetTimelinesByChannelId",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetTimelinesByChannelId(ctx, req.(*GetTimelinesByChannelIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetTimelineIdsByClipId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetTimelineIdsByClipIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetTimelineIdsByClipId(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetTimelineIdsByClipId",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetTimelineIdsByClipId(ctx, req.(*GetTimelineIdsByClipIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetTimelinesLiteByChannelId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetTimelinesLiteByChannelIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetTimelinesLiteByChannelId(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetTimelinesLiteByChannelId",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetTimelinesLiteByChannelId(ctx, req.(*GetTimelinesLiteByChannelIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetDocumentsBetweenStartDates_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(GetDocumentsBetweenStartDatesRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(TimelineManagerServer).GetDocumentsBetweenStartDates(m, &timelineManagerGetDocumentsBetweenStartDatesServer{stream})
}

type TimelineManager_GetDocumentsBetweenStartDatesServer interface {
	Send(*Timeline) error
	grpc.ServerStream
}

type timelineManagerGetDocumentsBetweenStartDatesServer struct {
	grpc.ServerStream
}

func (x *timelineManagerGetDocumentsBetweenStartDatesServer) Send(m *Timeline) error {
	return x.ServerStream.SendMsg(m)
}

func _TimelineManager_AggregateByEpisodes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AggregateByEpisodesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).AggregateByEpisodes(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/AggregateByEpisodes",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).AggregateByEpisodes(ctx, req.(*AggregateByEpisodesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _TimelineManager_GetAllBy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetAllByRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(TimelineManagerServer).GetAllBy(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/timelinepackage.TimelineManager/GetAllBy",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(TimelineManagerServer).GetAllBy(ctx, req.(*GetAllByRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// TimelineManager_ServiceDesc is the grpc.ServiceDesc for TimelineManager service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var TimelineManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "timelinepackage.TimelineManager",
	HandlerType: (*TimelineManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetEmptyTimeline",
			Handler:    _TimelineManager_GetEmptyTimeline_Handler,
		},
		{
			MethodName: "GetById",
			Handler:    _TimelineManager_GetById_Handler,
		},
		{
			MethodName: "GetByIds",
			Handler:    _TimelineManager_GetByIds_Handler,
		},
		{
			MethodName: "GetByEpisodeId",
			Handler:    _TimelineManager_GetByEpisodeId_Handler,
		},
		{
			MethodName: "GetTimelineById",
			Handler:    _TimelineManager_GetTimelineById_Handler,
		},
		{
			MethodName: "GetOne",
			Handler:    _TimelineManager_GetOne_Handler,
		},
		{
			MethodName: "DeleteById",
			Handler:    _TimelineManager_DeleteById_Handler,
		},
		{
			MethodName: "Count",
			Handler:    _TimelineManager_Count_Handler,
		},
		{
			MethodName: "GetTimelinesForAutoSchedule",
			Handler:    _TimelineManager_GetTimelinesForAutoSchedule_Handler,
		},
		{
			MethodName: "GetTimelinesForRepeatSchedule",
			Handler:    _TimelineManager_GetTimelinesForRepeatSchedule_Handler,
		},
		{
			MethodName: "UpdateTimelinesBulk",
			Handler:    _TimelineManager_UpdateTimelinesBulk_Handler,
		},
		{
			MethodName: "GetPopulatedTimelinesByChannelId",
			Handler:    _TimelineManager_GetPopulatedTimelinesByChannelId_Handler,
		},
		{
			MethodName: "DeleteTimelinesInChannelByDates",
			Handler:    _TimelineManager_DeleteTimelinesInChannelByDates_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _TimelineManager_Create_Handler,
		},
		{
			MethodName: "GetTimelinesByChannelId",
			Handler:    _TimelineManager_GetTimelinesByChannelId_Handler,
		},
		{
			MethodName: "GetTimelineIdsByClipId",
			Handler:    _TimelineManager_GetTimelineIdsByClipId_Handler,
		},
		{
			MethodName: "GetTimelinesLiteByChannelId",
			Handler:    _TimelineManager_GetTimelinesLiteByChannelId_Handler,
		},
		{
			MethodName: "AggregateByEpisodes",
			Handler:    _TimelineManager_AggregateByEpisodes_Handler,
		},
		{
			MethodName: "GetAllBy",
			Handler:    _TimelineManager_GetAllBy_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetAll",
			Handler:       _TimelineManager_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetDocumentsUpdatedBetweenDatesOnChannel",
			Handler:       _TimelineManager_GetDocumentsUpdatedBetweenDatesOnChannel_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetDocumentsBetweenDates",
			Handler:       _TimelineManager_GetDocumentsBetweenDates_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CFeedsSyncDocuments",
			Handler:       _TimelineManager_CFeedsSyncDocuments_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CFeedsSyncAllIds",
			Handler:       _TimelineManager_CFeedsSyncAllIds_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetDocumentsBetweenStartDates",
			Handler:       _TimelineManager_GetDocumentsBetweenStartDates_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "timelines/timelines.proto",
}