// 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

// SeriesManagerClient is the client API for SeriesManager 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 SeriesManagerClient interface {
	// GetById (Unary)
	GetById(ctx context.Context, in *GetByIdRequest, opts ...grpc.CallOption) (*GetByIdResponse, error)
	// GetPopulatedSeriesById (Unary)
	// The default populated episode when no `populate` is provided is the entire populated object. For performance
	// reason it may be desirable to request less / only needed values
	GetPopulatedSeriesById(ctx context.Context, in *GetPopulatedSeriesByIdRequest, opts ...grpc.CallOption) (*GetPopulatedSeriesByIdResponse, error)
	// GetByIds (Unary)
	GetByIds(ctx context.Context, in *GetByIdsRequest, opts ...grpc.CallOption) (*GetByIdsResponse, error)
	// GetDocumentsUpdatedBetweenDates (Server Stream)
	GetDocumentsUpdatedBetweenDates(ctx context.Context, in *GetDocumentsUpdatedBetweenDatesRequest, opts ...grpc.CallOption) (SeriesManager_GetDocumentsUpdatedBetweenDatesClient, error)
	// UpdateContentMamUniqueIdsByIds (Unary)
	UpdateContentMamUniqueIdsByIds(ctx context.Context, in *UpdateContentMamUniqueIdsByIdsRequest, opts ...grpc.CallOption) (*UpdateContentMamUniqueIdsByIdsResponse, error)
	// CFeedsSyncDocuments (Server Stream)
	CFeedsSyncDocuments(ctx context.Context, in *CFeedsSyncDocumentsRequest, opts ...grpc.CallOption) (SeriesManager_CFeedsSyncDocumentsClient, error)
	// CFeedsSyncAllIds (Server Stream)
	CFeedsSyncAllIds(ctx context.Context, in *CFeedsSyncAllIdsRequest, opts ...grpc.CallOption) (SeriesManager_CFeedsSyncAllIdsClient, error)
	// GetSeriesById (Unary)
	//
	// Deprecated. Will be removed once client (FW IVI) no longer using
	GetSeriesById(ctx context.Context, in *GetSeriesByIdRequest, opts ...grpc.CallOption) (*GetSeriesByIdResponse, error)
	UpdateFields(ctx context.Context, in *UpdateFieldsRequest, opts ...grpc.CallOption) (*UpdateFieldsResponse, error)
	// DeleteById (Unary)
	DeleteById(ctx context.Context, in *DeleteByIdRequest, opts ...grpc.CallOption) (*DeleteByIdResponse, error)
	// Create (Unary)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// GetSeriesUsingExternalId (Unary)
	// Retrieves series data based on an external identifier and additional query parameters.
	GetSeriesUsingExternalId(ctx context.Context, in *GetSeriesUsingExternalIdRequest, opts ...grpc.CallOption) (*GetSeriesUsingExternalIdResponse, error)
	// GetSeriesPartnerByIds (Unary)
	GetSeriesPartnerByIds(ctx context.Context, in *GetSeriesPartnerByIdsRequest, opts ...grpc.CallOption) (*GetSeriesPartnerByIdsResponse, error)
	// GetAllPaged (Unary)
	GetAllPaged(ctx context.Context, in *GetAllPagedRequest, opts ...grpc.CallOption) (*GetAllPagedResponse, error)
	// GetSeriesByChannelId (Unary)
	GetSeriesByChannelId(ctx context.Context, in *GetSeriesByChannelIdRequest, opts ...grpc.CallOption) (*GetSeriesByChannelIdResponse, error)
	// GetSeriesByNameAndActiveRegionAndCustomReferences (Unary)
	GetSeriesByNameAndActiveRegionAndCustomReferences(ctx context.Context, in *GetSeriesByNameAndActiveRegionAndCustomReferencesRequest, opts ...grpc.CallOption) (*GetSeriesByNameAndActiveRegionAndCustomReferenceResponse, error)
	// GetSeriesFutureTimeline
	GetSeriesFutureTimeline(ctx context.Context, in *GetSeriesFutureTimelineRequest, opts ...grpc.CallOption) (*GetSeriesFutureTimelineResponse, error)
	// UpdateRatings (Unary)
	UpdateRatings(ctx context.Context, in *UpdateRatingsRequest, opts ...grpc.CallOption) (*UpdateRatingsResponse, error)
}

type seriesManagerClient struct {
	cc grpc.ClientConnInterface
}

func NewSeriesManagerClient(cc grpc.ClientConnInterface) SeriesManagerClient {
	return &seriesManagerClient{cc}
}

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

func (c *seriesManagerClient) GetPopulatedSeriesById(ctx context.Context, in *GetPopulatedSeriesByIdRequest, opts ...grpc.CallOption) (*GetPopulatedSeriesByIdResponse, error) {
	out := new(GetPopulatedSeriesByIdResponse)
	err := c.cc.Invoke(ctx, "/seriespackage.SeriesManager/GetPopulatedSeriesById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

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

func (c *seriesManagerClient) GetDocumentsUpdatedBetweenDates(ctx context.Context, in *GetDocumentsUpdatedBetweenDatesRequest, opts ...grpc.CallOption) (SeriesManager_GetDocumentsUpdatedBetweenDatesClient, error) {
	stream, err := c.cc.NewStream(ctx, &SeriesManager_ServiceDesc.Streams[0], "/seriespackage.SeriesManager/GetDocumentsUpdatedBetweenDates", opts...)
	if err != nil {
		return nil, err
	}
	x := &seriesManagerGetDocumentsUpdatedBetweenDatesClient{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 SeriesManager_GetDocumentsUpdatedBetweenDatesClient interface {
	Recv() (*Series, error)
	grpc.ClientStream
}

type seriesManagerGetDocumentsUpdatedBetweenDatesClient struct {
	grpc.ClientStream
}

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

func (c *seriesManagerClient) UpdateContentMamUniqueIdsByIds(ctx context.Context, in *UpdateContentMamUniqueIdsByIdsRequest, opts ...grpc.CallOption) (*UpdateContentMamUniqueIdsByIdsResponse, error) {
	out := new(UpdateContentMamUniqueIdsByIdsResponse)
	err := c.cc.Invoke(ctx, "/seriespackage.SeriesManager/UpdateContentMamUniqueIdsByIds", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *seriesManagerClient) CFeedsSyncDocuments(ctx context.Context, in *CFeedsSyncDocumentsRequest, opts ...grpc.CallOption) (SeriesManager_CFeedsSyncDocumentsClient, error) {
	stream, err := c.cc.NewStream(ctx, &SeriesManager_ServiceDesc.Streams[1], "/seriespackage.SeriesManager/CFeedsSyncDocuments", opts...)
	if err != nil {
		return nil, err
	}
	x := &seriesManagerCFeedsSyncDocumentsClient{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 SeriesManager_CFeedsSyncDocumentsClient interface {
	Recv() (*Series, error)
	grpc.ClientStream
}

type seriesManagerCFeedsSyncDocumentsClient struct {
	grpc.ClientStream
}

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

func (c *seriesManagerClient) CFeedsSyncAllIds(ctx context.Context, in *CFeedsSyncAllIdsRequest, opts ...grpc.CallOption) (SeriesManager_CFeedsSyncAllIdsClient, error) {
	stream, err := c.cc.NewStream(ctx, &SeriesManager_ServiceDesc.Streams[2], "/seriespackage.SeriesManager/CFeedsSyncAllIds", opts...)
	if err != nil {
		return nil, err
	}
	x := &seriesManagerCFeedsSyncAllIdsClient{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 SeriesManager_CFeedsSyncAllIdsClient interface {
	Recv() (*Id, error)
	grpc.ClientStream
}

type seriesManagerCFeedsSyncAllIdsClient struct {
	grpc.ClientStream
}

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

func (c *seriesManagerClient) GetSeriesById(ctx context.Context, in *GetSeriesByIdRequest, opts ...grpc.CallOption) (*GetSeriesByIdResponse, error) {
	out := new(GetSeriesByIdResponse)
	err := c.cc.Invoke(ctx, "/seriespackage.SeriesManager/GetSeriesById", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *seriesManagerClient) UpdateFields(ctx context.Context, in *UpdateFieldsRequest, opts ...grpc.CallOption) (*UpdateFieldsResponse, error) {
	out := new(UpdateFieldsResponse)
	err := c.cc.Invoke(ctx, "/seriespackage.SeriesManager/UpdateFields", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

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

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

func (c *seriesManagerClient) GetSeriesUsingExternalId(ctx context.Context, in *GetSeriesUsingExternalIdRequest, opts ...grpc.CallOption) (*GetSeriesUsingExternalIdResponse, error) {
	out := new(GetSeriesUsingExternalIdResponse)
	err := c.cc.Invoke(ctx, "/seriespackage.SeriesManager/GetSeriesUsingExternalId", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *seriesManagerClient) GetSeriesPartnerByIds(ctx context.Context, in *GetSeriesPartnerByIdsRequest, opts ...grpc.CallOption) (*GetSeriesPartnerByIdsResponse, error) {
	out := new(GetSeriesPartnerByIdsResponse)
	err := c.cc.Invoke(ctx, "/seriespackage.SeriesManager/GetSeriesPartnerByIds", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *seriesManagerClient) GetAllPaged(ctx context.Context, in *GetAllPagedRequest, opts ...grpc.CallOption) (*GetAllPagedResponse, error) {
	out := new(GetAllPagedResponse)
	err := c.cc.Invoke(ctx, "/seriespackage.SeriesManager/GetAllPaged", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *seriesManagerClient) GetSeriesByChannelId(ctx context.Context, in *GetSeriesByChannelIdRequest, opts ...grpc.CallOption) (*GetSeriesByChannelIdResponse, error) {
	out := new(GetSeriesByChannelIdResponse)
	err := c.cc.Invoke(ctx, "/seriespackage.SeriesManager/GetSeriesByChannelId", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *seriesManagerClient) GetSeriesByNameAndActiveRegionAndCustomReferences(ctx context.Context, in *GetSeriesByNameAndActiveRegionAndCustomReferencesRequest, opts ...grpc.CallOption) (*GetSeriesByNameAndActiveRegionAndCustomReferenceResponse, error) {
	out := new(GetSeriesByNameAndActiveRegionAndCustomReferenceResponse)
	err := c.cc.Invoke(ctx, "/seriespackage.SeriesManager/GetSeriesByNameAndActiveRegionAndCustomReferences", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *seriesManagerClient) GetSeriesFutureTimeline(ctx context.Context, in *GetSeriesFutureTimelineRequest, opts ...grpc.CallOption) (*GetSeriesFutureTimelineResponse, error) {
	out := new(GetSeriesFutureTimelineResponse)
	err := c.cc.Invoke(ctx, "/seriespackage.SeriesManager/GetSeriesFutureTimeline", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *seriesManagerClient) UpdateRatings(ctx context.Context, in *UpdateRatingsRequest, opts ...grpc.CallOption) (*UpdateRatingsResponse, error) {
	out := new(UpdateRatingsResponse)
	err := c.cc.Invoke(ctx, "/seriespackage.SeriesManager/UpdateRatings", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// SeriesManagerServer is the server API for SeriesManager service.
// All implementations must embed UnimplementedSeriesManagerServer
// for forward compatibility
type SeriesManagerServer interface {
	// GetById (Unary)
	GetById(context.Context, *GetByIdRequest) (*GetByIdResponse, error)
	// GetPopulatedSeriesById (Unary)
	// The default populated episode when no `populate` is provided is the entire populated object. For performance
	// reason it may be desirable to request less / only needed values
	GetPopulatedSeriesById(context.Context, *GetPopulatedSeriesByIdRequest) (*GetPopulatedSeriesByIdResponse, error)
	// GetByIds (Unary)
	GetByIds(context.Context, *GetByIdsRequest) (*GetByIdsResponse, error)
	// GetDocumentsUpdatedBetweenDates (Server Stream)
	GetDocumentsUpdatedBetweenDates(*GetDocumentsUpdatedBetweenDatesRequest, SeriesManager_GetDocumentsUpdatedBetweenDatesServer) error
	// UpdateContentMamUniqueIdsByIds (Unary)
	UpdateContentMamUniqueIdsByIds(context.Context, *UpdateContentMamUniqueIdsByIdsRequest) (*UpdateContentMamUniqueIdsByIdsResponse, error)
	// CFeedsSyncDocuments (Server Stream)
	CFeedsSyncDocuments(*CFeedsSyncDocumentsRequest, SeriesManager_CFeedsSyncDocumentsServer) error
	// CFeedsSyncAllIds (Server Stream)
	CFeedsSyncAllIds(*CFeedsSyncAllIdsRequest, SeriesManager_CFeedsSyncAllIdsServer) error
	// GetSeriesById (Unary)
	//
	// Deprecated. Will be removed once client (FW IVI) no longer using
	GetSeriesById(context.Context, *GetSeriesByIdRequest) (*GetSeriesByIdResponse, error)
	UpdateFields(context.Context, *UpdateFieldsRequest) (*UpdateFieldsResponse, error)
	// DeleteById (Unary)
	DeleteById(context.Context, *DeleteByIdRequest) (*DeleteByIdResponse, error)
	// Create (Unary)
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// GetSeriesUsingExternalId (Unary)
	// Retrieves series data based on an external identifier and additional query parameters.
	GetSeriesUsingExternalId(context.Context, *GetSeriesUsingExternalIdRequest) (*GetSeriesUsingExternalIdResponse, error)
	// GetSeriesPartnerByIds (Unary)
	GetSeriesPartnerByIds(context.Context, *GetSeriesPartnerByIdsRequest) (*GetSeriesPartnerByIdsResponse, error)
	// GetAllPaged (Unary)
	GetAllPaged(context.Context, *GetAllPagedRequest) (*GetAllPagedResponse, error)
	// GetSeriesByChannelId (Unary)
	GetSeriesByChannelId(context.Context, *GetSeriesByChannelIdRequest) (*GetSeriesByChannelIdResponse, error)
	// GetSeriesByNameAndActiveRegionAndCustomReferences (Unary)
	GetSeriesByNameAndActiveRegionAndCustomReferences(context.Context, *GetSeriesByNameAndActiveRegionAndCustomReferencesRequest) (*GetSeriesByNameAndActiveRegionAndCustomReferenceResponse, error)
	// GetSeriesFutureTimeline
	GetSeriesFutureTimeline(context.Context, *GetSeriesFutureTimelineRequest) (*GetSeriesFutureTimelineResponse, error)
	// UpdateRatings (Unary)
	UpdateRatings(context.Context, *UpdateRatingsRequest) (*UpdateRatingsResponse, error)
	mustEmbedUnimplementedSeriesManagerServer()
}

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

func (UnimplementedSeriesManagerServer) GetById(context.Context, *GetByIdRequest) (*GetByIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetById not implemented")
}
func (UnimplementedSeriesManagerServer) GetPopulatedSeriesById(context.Context, *GetPopulatedSeriesByIdRequest) (*GetPopulatedSeriesByIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPopulatedSeriesById not implemented")
}
func (UnimplementedSeriesManagerServer) GetByIds(context.Context, *GetByIdsRequest) (*GetByIdsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetByIds not implemented")
}
func (UnimplementedSeriesManagerServer) GetDocumentsUpdatedBetweenDates(*GetDocumentsUpdatedBetweenDatesRequest, SeriesManager_GetDocumentsUpdatedBetweenDatesServer) error {
	return status.Errorf(codes.Unimplemented, "method GetDocumentsUpdatedBetweenDates not implemented")
}
func (UnimplementedSeriesManagerServer) UpdateContentMamUniqueIdsByIds(context.Context, *UpdateContentMamUniqueIdsByIdsRequest) (*UpdateContentMamUniqueIdsByIdsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateContentMamUniqueIdsByIds not implemented")
}
func (UnimplementedSeriesManagerServer) CFeedsSyncDocuments(*CFeedsSyncDocumentsRequest, SeriesManager_CFeedsSyncDocumentsServer) error {
	return status.Errorf(codes.Unimplemented, "method CFeedsSyncDocuments not implemented")
}
func (UnimplementedSeriesManagerServer) CFeedsSyncAllIds(*CFeedsSyncAllIdsRequest, SeriesManager_CFeedsSyncAllIdsServer) error {
	return status.Errorf(codes.Unimplemented, "method CFeedsSyncAllIds not implemented")
}
func (UnimplementedSeriesManagerServer) GetSeriesById(context.Context, *GetSeriesByIdRequest) (*GetSeriesByIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSeriesById not implemented")
}
func (UnimplementedSeriesManagerServer) UpdateFields(context.Context, *UpdateFieldsRequest) (*UpdateFieldsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateFields not implemented")
}
func (UnimplementedSeriesManagerServer) DeleteById(context.Context, *DeleteByIdRequest) (*DeleteByIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteById not implemented")
}
func (UnimplementedSeriesManagerServer) Create(context.Context, *CreateRequest) (*CreateResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Create not implemented")
}
func (UnimplementedSeriesManagerServer) GetSeriesUsingExternalId(context.Context, *GetSeriesUsingExternalIdRequest) (*GetSeriesUsingExternalIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSeriesUsingExternalId not implemented")
}
func (UnimplementedSeriesManagerServer) GetSeriesPartnerByIds(context.Context, *GetSeriesPartnerByIdsRequest) (*GetSeriesPartnerByIdsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSeriesPartnerByIds not implemented")
}
func (UnimplementedSeriesManagerServer) GetAllPaged(context.Context, *GetAllPagedRequest) (*GetAllPagedResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetAllPaged not implemented")
}
func (UnimplementedSeriesManagerServer) GetSeriesByChannelId(context.Context, *GetSeriesByChannelIdRequest) (*GetSeriesByChannelIdResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSeriesByChannelId not implemented")
}
func (UnimplementedSeriesManagerServer) GetSeriesByNameAndActiveRegionAndCustomReferences(context.Context, *GetSeriesByNameAndActiveRegionAndCustomReferencesRequest) (*GetSeriesByNameAndActiveRegionAndCustomReferenceResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSeriesByNameAndActiveRegionAndCustomReferences not implemented")
}
func (UnimplementedSeriesManagerServer) GetSeriesFutureTimeline(context.Context, *GetSeriesFutureTimelineRequest) (*GetSeriesFutureTimelineResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSeriesFutureTimeline not implemented")
}
func (UnimplementedSeriesManagerServer) UpdateRatings(context.Context, *UpdateRatingsRequest) (*UpdateRatingsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateRatings not implemented")
}
func (UnimplementedSeriesManagerServer) mustEmbedUnimplementedSeriesManagerServer() {}

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

func RegisterSeriesManagerServer(s grpc.ServiceRegistrar, srv SeriesManagerServer) {
	s.RegisterService(&SeriesManager_ServiceDesc, srv)
}

func _SeriesManager_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.(SeriesManagerServer).GetById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/GetById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).GetById(ctx, req.(*GetByIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_GetPopulatedSeriesById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPopulatedSeriesByIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SeriesManagerServer).GetPopulatedSeriesById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/GetPopulatedSeriesById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).GetPopulatedSeriesById(ctx, req.(*GetPopulatedSeriesByIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_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.(SeriesManagerServer).GetByIds(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/GetByIds",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).GetByIds(ctx, req.(*GetByIdsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_GetDocumentsUpdatedBetweenDates_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(GetDocumentsUpdatedBetweenDatesRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(SeriesManagerServer).GetDocumentsUpdatedBetweenDates(m, &seriesManagerGetDocumentsUpdatedBetweenDatesServer{stream})
}

type SeriesManager_GetDocumentsUpdatedBetweenDatesServer interface {
	Send(*Series) error
	grpc.ServerStream
}

type seriesManagerGetDocumentsUpdatedBetweenDatesServer struct {
	grpc.ServerStream
}

func (x *seriesManagerGetDocumentsUpdatedBetweenDatesServer) Send(m *Series) error {
	return x.ServerStream.SendMsg(m)
}

func _SeriesManager_UpdateContentMamUniqueIdsByIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateContentMamUniqueIdsByIdsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SeriesManagerServer).UpdateContentMamUniqueIdsByIds(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/UpdateContentMamUniqueIdsByIds",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).UpdateContentMamUniqueIdsByIds(ctx, req.(*UpdateContentMamUniqueIdsByIdsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

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

type SeriesManager_CFeedsSyncDocumentsServer interface {
	Send(*Series) error
	grpc.ServerStream
}

type seriesManagerCFeedsSyncDocumentsServer struct {
	grpc.ServerStream
}

func (x *seriesManagerCFeedsSyncDocumentsServer) Send(m *Series) error {
	return x.ServerStream.SendMsg(m)
}

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

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

type seriesManagerCFeedsSyncAllIdsServer struct {
	grpc.ServerStream
}

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

func _SeriesManager_GetSeriesById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSeriesByIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SeriesManagerServer).GetSeriesById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/GetSeriesById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).GetSeriesById(ctx, req.(*GetSeriesByIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_UpdateFields_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateFieldsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SeriesManagerServer).UpdateFields(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/UpdateFields",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).UpdateFields(ctx, req.(*UpdateFieldsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_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.(SeriesManagerServer).DeleteById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/DeleteById",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).DeleteById(ctx, req.(*DeleteByIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_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.(SeriesManagerServer).Create(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/Create",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).Create(ctx, req.(*CreateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_GetSeriesUsingExternalId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSeriesUsingExternalIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SeriesManagerServer).GetSeriesUsingExternalId(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/GetSeriesUsingExternalId",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).GetSeriesUsingExternalId(ctx, req.(*GetSeriesUsingExternalIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_GetSeriesPartnerByIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSeriesPartnerByIdsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SeriesManagerServer).GetSeriesPartnerByIds(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/GetSeriesPartnerByIds",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).GetSeriesPartnerByIds(ctx, req.(*GetSeriesPartnerByIdsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_GetAllPaged_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetAllPagedRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SeriesManagerServer).GetAllPaged(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/GetAllPaged",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).GetAllPaged(ctx, req.(*GetAllPagedRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_GetSeriesByChannelId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSeriesByChannelIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SeriesManagerServer).GetSeriesByChannelId(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/GetSeriesByChannelId",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).GetSeriesByChannelId(ctx, req.(*GetSeriesByChannelIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_GetSeriesByNameAndActiveRegionAndCustomReferences_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSeriesByNameAndActiveRegionAndCustomReferencesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SeriesManagerServer).GetSeriesByNameAndActiveRegionAndCustomReferences(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/GetSeriesByNameAndActiveRegionAndCustomReferences",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).GetSeriesByNameAndActiveRegionAndCustomReferences(ctx, req.(*GetSeriesByNameAndActiveRegionAndCustomReferencesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_GetSeriesFutureTimeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSeriesFutureTimelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SeriesManagerServer).GetSeriesFutureTimeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/GetSeriesFutureTimeline",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).GetSeriesFutureTimeline(ctx, req.(*GetSeriesFutureTimelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SeriesManager_UpdateRatings_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateRatingsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SeriesManagerServer).UpdateRatings(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/seriespackage.SeriesManager/UpdateRatings",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SeriesManagerServer).UpdateRatings(ctx, req.(*UpdateRatingsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// SeriesManager_ServiceDesc is the grpc.ServiceDesc for SeriesManager service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var SeriesManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "seriespackage.SeriesManager",
	HandlerType: (*SeriesManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetById",
			Handler:    _SeriesManager_GetById_Handler,
		},
		{
			MethodName: "GetPopulatedSeriesById",
			Handler:    _SeriesManager_GetPopulatedSeriesById_Handler,
		},
		{
			MethodName: "GetByIds",
			Handler:    _SeriesManager_GetByIds_Handler,
		},
		{
			MethodName: "UpdateContentMamUniqueIdsByIds",
			Handler:    _SeriesManager_UpdateContentMamUniqueIdsByIds_Handler,
		},
		{
			MethodName: "GetSeriesById",
			Handler:    _SeriesManager_GetSeriesById_Handler,
		},
		{
			MethodName: "UpdateFields",
			Handler:    _SeriesManager_UpdateFields_Handler,
		},
		{
			MethodName: "DeleteById",
			Handler:    _SeriesManager_DeleteById_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _SeriesManager_Create_Handler,
		},
		{
			MethodName: "GetSeriesUsingExternalId",
			Handler:    _SeriesManager_GetSeriesUsingExternalId_Handler,
		},
		{
			MethodName: "GetSeriesPartnerByIds",
			Handler:    _SeriesManager_GetSeriesPartnerByIds_Handler,
		},
		{
			MethodName: "GetAllPaged",
			Handler:    _SeriesManager_GetAllPaged_Handler,
		},
		{
			MethodName: "GetSeriesByChannelId",
			Handler:    _SeriesManager_GetSeriesByChannelId_Handler,
		},
		{
			MethodName: "GetSeriesByNameAndActiveRegionAndCustomReferences",
			Handler:    _SeriesManager_GetSeriesByNameAndActiveRegionAndCustomReferences_Handler,
		},
		{
			MethodName: "GetSeriesFutureTimeline",
			Handler:    _SeriesManager_GetSeriesFutureTimeline_Handler,
		},
		{
			MethodName: "UpdateRatings",
			Handler:    _SeriesManager_UpdateRatings_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetDocumentsUpdatedBetweenDates",
			Handler:       _SeriesManager_GetDocumentsUpdatedBetweenDates_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CFeedsSyncDocuments",
			Handler:       _SeriesManager_CFeedsSyncDocuments_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CFeedsSyncAllIds",
			Handler:       _SeriesManager_CFeedsSyncAllIds_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "series/series.proto",
}