Documentation
¶
Overview ¶
Package grpc_animeaggregatoradmin_v1 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func RegisterAnimeAggregatorAdminServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAnimeAggregatorAdminServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, ...) error
- func RegisterAnimeAggregatorAdminServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAnimeAggregatorAdminServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, ...) error
- func RegisterAnimeAggregatorAdminServiceServer(s grpc.ServiceRegistrar, srv AnimeAggregatorAdminServiceServer)
- type AnimeAggregatorAdminServiceClient
- type AnimeAggregatorAdminServiceServer
- type RefreshAggregateIndexesRequest
- func (*RefreshAggregateIndexesRequest) Descriptor() ([]byte, []int)deprecated
- func (*RefreshAggregateIndexesRequest) ProtoMessage()
- func (x *RefreshAggregateIndexesRequest) ProtoReflect() protoreflect.Message
- func (x *RefreshAggregateIndexesRequest) Reset()
- func (x *RefreshAggregateIndexesRequest) String() string
- type RefreshAggregateIndexesResponse
- func (*RefreshAggregateIndexesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshAggregateIndexesResponse) GetAnimeCount() int32
- func (x *RefreshAggregateIndexesResponse) GetFormatCount() int32
- func (x *RefreshAggregateIndexesResponse) GetGenreCount() int32
- func (x *RefreshAggregateIndexesResponse) GetSeasonCount() int32
- func (x *RefreshAggregateIndexesResponse) GetSeasonYearCount() int32
- func (x *RefreshAggregateIndexesResponse) GetStatusCount() int32
- func (x *RefreshAggregateIndexesResponse) GetStudioCount() int32
- func (x *RefreshAggregateIndexesResponse) GetTagCount() int32
- func (x *RefreshAggregateIndexesResponse) GetTitleCount() int32
- func (*RefreshAggregateIndexesResponse) ProtoMessage()
- func (x *RefreshAggregateIndexesResponse) ProtoReflect() protoreflect.Message
- func (x *RefreshAggregateIndexesResponse) Reset()
- func (x *RefreshAggregateIndexesResponse) String() string
- type RefreshAllRequest
- type RefreshAllResponse
- func (*RefreshAllResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshAllResponse) GetAnimes() *RefreshAnimesResponse
- func (x *RefreshAllResponse) GetMappings() *RefreshMappingsResponse
- func (*RefreshAllResponse) ProtoMessage()
- func (x *RefreshAllResponse) ProtoReflect() protoreflect.Message
- func (x *RefreshAllResponse) Reset()
- func (x *RefreshAllResponse) String() string
- type RefreshAnimesRequest
- func (*RefreshAnimesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshAnimesRequest) GetIds() []string
- func (x *RefreshAnimesRequest) GetProvider() v1.AnimeProvider
- func (*RefreshAnimesRequest) ProtoMessage()
- func (x *RefreshAnimesRequest) ProtoReflect() protoreflect.Message
- func (x *RefreshAnimesRequest) Reset()
- func (x *RefreshAnimesRequest) String() string
- type RefreshAnimesResponse
- type RefreshMappingsRequest
- type RefreshMappingsResponse
- func (*RefreshMappingsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshMappingsResponse) GetUpdated() map[string]int64
- func (*RefreshMappingsResponse) ProtoMessage()
- func (x *RefreshMappingsResponse) ProtoReflect() protoreflect.Message
- func (x *RefreshMappingsResponse) Reset()
- func (x *RefreshMappingsResponse) String() string
- type UnimplementedAnimeAggregatorAdminServiceServer
- func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshAggregateIndexes(context.Context, *RefreshAggregateIndexesRequest) (*RefreshAggregateIndexesResponse, error)
- func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshAll(context.Context, *RefreshAllRequest) (*RefreshAllResponse, error)
- func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshAnimes(context.Context, *RefreshAnimesRequest) (*RefreshAnimesResponse, error)
- func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshMappings(context.Context, *RefreshMappingsRequest) (*RefreshMappingsResponse, error)
- type UnsafeAnimeAggregatorAdminServiceServer
Constants ¶
const ( AnimeAggregatorAdminService_RefreshAll_FullMethodName = "/grpc_animeaggregatoradmin.v1.AnimeAggregatorAdminService/RefreshAll" AnimeAggregatorAdminService_RefreshAnimes_FullMethodName = "/grpc_animeaggregatoradmin.v1.AnimeAggregatorAdminService/RefreshAnimes" AnimeAggregatorAdminService_RefreshMappings_FullMethodName = "/grpc_animeaggregatoradmin.v1.AnimeAggregatorAdminService/RefreshMappings" AnimeAggregatorAdminService_RefreshAggregateIndexes_FullMethodName = "/grpc_animeaggregatoradmin.v1.AnimeAggregatorAdminService/RefreshAggregateIndexes" )
Variables ¶
var AnimeAggregatorAdminService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc_animeaggregatoradmin.v1.AnimeAggregatorAdminService", HandlerType: (*AnimeAggregatorAdminServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RefreshAll", Handler: _AnimeAggregatorAdminService_RefreshAll_Handler, }, { MethodName: "RefreshAnimes", Handler: _AnimeAggregatorAdminService_RefreshAnimes_Handler, }, { MethodName: "RefreshMappings", Handler: _AnimeAggregatorAdminService_RefreshMappings_Handler, }, { MethodName: "RefreshAggregateIndexes", Handler: _AnimeAggregatorAdminService_RefreshAggregateIndexes_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/grpc_animeaggregatoradmin/v1/grpc_animeaggregatoradmin.proto", }
AnimeAggregatorAdminService_ServiceDesc is the grpc.ServiceDesc for AnimeAggregatorAdminService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_api_grpc_animeaggregatoradmin_v1_grpc_animeaggregatoradmin_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAnimeAggregatorAdminServiceHandler ¶
func RegisterAnimeAggregatorAdminServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterAnimeAggregatorAdminServiceHandler registers the http handlers for service AnimeAggregatorAdminService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterAnimeAggregatorAdminServiceHandlerClient ¶
func RegisterAnimeAggregatorAdminServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AnimeAggregatorAdminServiceClient) error
RegisterAnimeAggregatorAdminServiceHandlerClient registers the http handlers for service AnimeAggregatorAdminService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AnimeAggregatorAdminServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AnimeAggregatorAdminServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AnimeAggregatorAdminServiceClient" to call the correct interceptors.
func RegisterAnimeAggregatorAdminServiceHandlerFromEndpoint ¶
func RegisterAnimeAggregatorAdminServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterAnimeAggregatorAdminServiceHandlerFromEndpoint is same as RegisterAnimeAggregatorAdminServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAnimeAggregatorAdminServiceHandlerServer ¶
func RegisterAnimeAggregatorAdminServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AnimeAggregatorAdminServiceServer) error
RegisterAnimeAggregatorAdminServiceHandlerServer registers the http handlers for service AnimeAggregatorAdminService to "mux". UnaryRPC :call AnimeAggregatorAdminServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAnimeAggregatorAdminServiceHandlerFromEndpoint instead.
func RegisterAnimeAggregatorAdminServiceServer ¶
func RegisterAnimeAggregatorAdminServiceServer(s grpc.ServiceRegistrar, srv AnimeAggregatorAdminServiceServer)
Types ¶
type AnimeAggregatorAdminServiceClient ¶
type AnimeAggregatorAdminServiceClient interface { RefreshAll(ctx context.Context, in *RefreshAllRequest, opts ...grpc.CallOption) (*RefreshAllResponse, error) RefreshAnimes(ctx context.Context, in *RefreshAnimesRequest, opts ...grpc.CallOption) (*RefreshAnimesResponse, error) RefreshMappings(ctx context.Context, in *RefreshMappingsRequest, opts ...grpc.CallOption) (*RefreshMappingsResponse, error) RefreshAggregateIndexes(ctx context.Context, in *RefreshAggregateIndexesRequest, opts ...grpc.CallOption) (*RefreshAggregateIndexesResponse, error) }
AnimeAggregatorAdminServiceClient is the client API for AnimeAggregatorAdminService 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 NewAnimeAggregatorAdminServiceClient ¶
func NewAnimeAggregatorAdminServiceClient(cc grpc.ClientConnInterface) AnimeAggregatorAdminServiceClient
type AnimeAggregatorAdminServiceServer ¶
type AnimeAggregatorAdminServiceServer interface { RefreshAll(context.Context, *RefreshAllRequest) (*RefreshAllResponse, error) RefreshAnimes(context.Context, *RefreshAnimesRequest) (*RefreshAnimesResponse, error) RefreshMappings(context.Context, *RefreshMappingsRequest) (*RefreshMappingsResponse, error) RefreshAggregateIndexes(context.Context, *RefreshAggregateIndexesRequest) (*RefreshAggregateIndexesResponse, error) // contains filtered or unexported methods }
AnimeAggregatorAdminServiceServer is the server API for AnimeAggregatorAdminService service. All implementations must embed UnimplementedAnimeAggregatorAdminServiceServer for forward compatibility
type RefreshAggregateIndexesRequest ¶
type RefreshAggregateIndexesRequest struct {
// contains filtered or unexported fields
}
func (*RefreshAggregateIndexesRequest) Descriptor
deprecated
func (*RefreshAggregateIndexesRequest) Descriptor() ([]byte, []int)
Deprecated: Use RefreshAggregateIndexesRequest.ProtoReflect.Descriptor instead.
func (*RefreshAggregateIndexesRequest) ProtoMessage ¶
func (*RefreshAggregateIndexesRequest) ProtoMessage()
func (*RefreshAggregateIndexesRequest) ProtoReflect ¶
func (x *RefreshAggregateIndexesRequest) ProtoReflect() protoreflect.Message
func (*RefreshAggregateIndexesRequest) Reset ¶
func (x *RefreshAggregateIndexesRequest) Reset()
func (*RefreshAggregateIndexesRequest) String ¶
func (x *RefreshAggregateIndexesRequest) String() string
type RefreshAggregateIndexesResponse ¶
type RefreshAggregateIndexesResponse struct { AnimeCount int32 `protobuf:"fixed32,1,opt,name=anime_count,json=animeCount,proto3" json:"anime_count,omitempty"` TagCount int32 `protobuf:"fixed32,2,opt,name=tag_count,json=tagCount,proto3" json:"tag_count,omitempty"` GenreCount int32 `protobuf:"fixed32,3,opt,name=genre_count,json=genreCount,proto3" json:"genre_count,omitempty"` StudioCount int32 `protobuf:"fixed32,4,opt,name=studio_count,json=studioCount,proto3" json:"studio_count,omitempty"` SeasonYearCount int32 `protobuf:"fixed32,5,opt,name=season_year_count,json=seasonYearCount,proto3" json:"season_year_count,omitempty"` SeasonCount int32 `protobuf:"fixed32,6,opt,name=season_count,json=seasonCount,proto3" json:"season_count,omitempty"` FormatCount int32 `protobuf:"fixed32,7,opt,name=format_count,json=formatCount,proto3" json:"format_count,omitempty"` StatusCount int32 `protobuf:"fixed32,8,opt,name=status_count,json=statusCount,proto3" json:"status_count,omitempty"` TitleCount int32 `protobuf:"fixed32,9,opt,name=title_count,json=titleCount,proto3" json:"title_count,omitempty"` // contains filtered or unexported fields }
func (*RefreshAggregateIndexesResponse) Descriptor
deprecated
func (*RefreshAggregateIndexesResponse) Descriptor() ([]byte, []int)
Deprecated: Use RefreshAggregateIndexesResponse.ProtoReflect.Descriptor instead.
func (*RefreshAggregateIndexesResponse) GetAnimeCount ¶
func (x *RefreshAggregateIndexesResponse) GetAnimeCount() int32
func (*RefreshAggregateIndexesResponse) GetFormatCount ¶
func (x *RefreshAggregateIndexesResponse) GetFormatCount() int32
func (*RefreshAggregateIndexesResponse) GetGenreCount ¶
func (x *RefreshAggregateIndexesResponse) GetGenreCount() int32
func (*RefreshAggregateIndexesResponse) GetSeasonCount ¶
func (x *RefreshAggregateIndexesResponse) GetSeasonCount() int32
func (*RefreshAggregateIndexesResponse) GetSeasonYearCount ¶
func (x *RefreshAggregateIndexesResponse) GetSeasonYearCount() int32
func (*RefreshAggregateIndexesResponse) GetStatusCount ¶
func (x *RefreshAggregateIndexesResponse) GetStatusCount() int32
func (*RefreshAggregateIndexesResponse) GetStudioCount ¶
func (x *RefreshAggregateIndexesResponse) GetStudioCount() int32
func (*RefreshAggregateIndexesResponse) GetTagCount ¶
func (x *RefreshAggregateIndexesResponse) GetTagCount() int32
func (*RefreshAggregateIndexesResponse) GetTitleCount ¶
func (x *RefreshAggregateIndexesResponse) GetTitleCount() int32
func (*RefreshAggregateIndexesResponse) ProtoMessage ¶
func (*RefreshAggregateIndexesResponse) ProtoMessage()
func (*RefreshAggregateIndexesResponse) ProtoReflect ¶
func (x *RefreshAggregateIndexesResponse) ProtoReflect() protoreflect.Message
func (*RefreshAggregateIndexesResponse) Reset ¶
func (x *RefreshAggregateIndexesResponse) Reset()
func (*RefreshAggregateIndexesResponse) String ¶
func (x *RefreshAggregateIndexesResponse) String() string
type RefreshAllRequest ¶
type RefreshAllRequest struct {
// contains filtered or unexported fields
}
func (*RefreshAllRequest) Descriptor
deprecated
func (*RefreshAllRequest) Descriptor() ([]byte, []int)
Deprecated: Use RefreshAllRequest.ProtoReflect.Descriptor instead.
func (*RefreshAllRequest) ProtoMessage ¶
func (*RefreshAllRequest) ProtoMessage()
func (*RefreshAllRequest) ProtoReflect ¶
func (x *RefreshAllRequest) ProtoReflect() protoreflect.Message
func (*RefreshAllRequest) Reset ¶
func (x *RefreshAllRequest) Reset()
func (*RefreshAllRequest) String ¶
func (x *RefreshAllRequest) String() string
type RefreshAllResponse ¶
type RefreshAllResponse struct { Mappings *RefreshMappingsResponse `protobuf:"bytes,1,opt,name=mappings,proto3,oneof" json:"mappings,omitempty"` Animes *RefreshAnimesResponse `protobuf:"bytes,2,opt,name=animes,proto3,oneof" json:"animes,omitempty"` // contains filtered or unexported fields }
func (*RefreshAllResponse) Descriptor
deprecated
func (*RefreshAllResponse) Descriptor() ([]byte, []int)
Deprecated: Use RefreshAllResponse.ProtoReflect.Descriptor instead.
func (*RefreshAllResponse) GetAnimes ¶
func (x *RefreshAllResponse) GetAnimes() *RefreshAnimesResponse
func (*RefreshAllResponse) GetMappings ¶
func (x *RefreshAllResponse) GetMappings() *RefreshMappingsResponse
func (*RefreshAllResponse) ProtoMessage ¶
func (*RefreshAllResponse) ProtoMessage()
func (*RefreshAllResponse) ProtoReflect ¶
func (x *RefreshAllResponse) ProtoReflect() protoreflect.Message
func (*RefreshAllResponse) Reset ¶
func (x *RefreshAllResponse) Reset()
func (*RefreshAllResponse) String ¶
func (x *RefreshAllResponse) String() string
type RefreshAnimesRequest ¶
type RefreshAnimesRequest struct { Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"` Provider *v1.AnimeProvider `` /* 126-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RefreshAnimesRequest) Descriptor
deprecated
func (*RefreshAnimesRequest) Descriptor() ([]byte, []int)
Deprecated: Use RefreshAnimesRequest.ProtoReflect.Descriptor instead.
func (*RefreshAnimesRequest) GetIds ¶
func (x *RefreshAnimesRequest) GetIds() []string
func (*RefreshAnimesRequest) GetProvider ¶
func (x *RefreshAnimesRequest) GetProvider() v1.AnimeProvider
func (*RefreshAnimesRequest) ProtoMessage ¶
func (*RefreshAnimesRequest) ProtoMessage()
func (*RefreshAnimesRequest) ProtoReflect ¶
func (x *RefreshAnimesRequest) ProtoReflect() protoreflect.Message
func (*RefreshAnimesRequest) Reset ¶
func (x *RefreshAnimesRequest) Reset()
func (*RefreshAnimesRequest) String ¶
func (x *RefreshAnimesRequest) String() string
type RefreshAnimesResponse ¶
type RefreshAnimesResponse struct {
// contains filtered or unexported fields
}
func (*RefreshAnimesResponse) Descriptor
deprecated
func (*RefreshAnimesResponse) Descriptor() ([]byte, []int)
Deprecated: Use RefreshAnimesResponse.ProtoReflect.Descriptor instead.
func (*RefreshAnimesResponse) ProtoMessage ¶
func (*RefreshAnimesResponse) ProtoMessage()
func (*RefreshAnimesResponse) ProtoReflect ¶
func (x *RefreshAnimesResponse) ProtoReflect() protoreflect.Message
func (*RefreshAnimesResponse) Reset ¶
func (x *RefreshAnimesResponse) Reset()
func (*RefreshAnimesResponse) String ¶
func (x *RefreshAnimesResponse) String() string
type RefreshMappingsRequest ¶
type RefreshMappingsRequest struct {
// contains filtered or unexported fields
}
func (*RefreshMappingsRequest) Descriptor
deprecated
func (*RefreshMappingsRequest) Descriptor() ([]byte, []int)
Deprecated: Use RefreshMappingsRequest.ProtoReflect.Descriptor instead.
func (*RefreshMappingsRequest) ProtoMessage ¶
func (*RefreshMappingsRequest) ProtoMessage()
func (*RefreshMappingsRequest) ProtoReflect ¶
func (x *RefreshMappingsRequest) ProtoReflect() protoreflect.Message
func (*RefreshMappingsRequest) Reset ¶
func (x *RefreshMappingsRequest) Reset()
func (*RefreshMappingsRequest) String ¶
func (x *RefreshMappingsRequest) String() string
type RefreshMappingsResponse ¶
type RefreshMappingsResponse struct { Updated map[string]int64 `` /* 156-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RefreshMappingsResponse) Descriptor
deprecated
func (*RefreshMappingsResponse) Descriptor() ([]byte, []int)
Deprecated: Use RefreshMappingsResponse.ProtoReflect.Descriptor instead.
func (*RefreshMappingsResponse) GetUpdated ¶
func (x *RefreshMappingsResponse) GetUpdated() map[string]int64
func (*RefreshMappingsResponse) ProtoMessage ¶
func (*RefreshMappingsResponse) ProtoMessage()
func (*RefreshMappingsResponse) ProtoReflect ¶
func (x *RefreshMappingsResponse) ProtoReflect() protoreflect.Message
func (*RefreshMappingsResponse) Reset ¶
func (x *RefreshMappingsResponse) Reset()
func (*RefreshMappingsResponse) String ¶
func (x *RefreshMappingsResponse) String() string
type UnimplementedAnimeAggregatorAdminServiceServer ¶
type UnimplementedAnimeAggregatorAdminServiceServer struct { }
UnimplementedAnimeAggregatorAdminServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshAggregateIndexes ¶
func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshAggregateIndexes(context.Context, *RefreshAggregateIndexesRequest) (*RefreshAggregateIndexesResponse, error)
func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshAll ¶
func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshAll(context.Context, *RefreshAllRequest) (*RefreshAllResponse, error)
func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshAnimes ¶
func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshAnimes(context.Context, *RefreshAnimesRequest) (*RefreshAnimesResponse, error)
func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshMappings ¶
func (UnimplementedAnimeAggregatorAdminServiceServer) RefreshMappings(context.Context, *RefreshMappingsRequest) (*RefreshMappingsResponse, error)
type UnsafeAnimeAggregatorAdminServiceServer ¶
type UnsafeAnimeAggregatorAdminServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAnimeAggregatorAdminServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AnimeAggregatorAdminServiceServer will result in compilation errors.