Documentation ¶
Index ¶
- Constants
- Variables
- func CreateJobStoreClient(conn *grpc.ClientConn, rpcTimeout time.Duration) *networkHandler
- func RegisterJobStoreServer(s grpc.ServiceRegistrar, srv JobStoreServer)
- type JobStoreClient
- type JobStoreServer
- type UnimplementedJobStoreServer
- func (UnimplementedJobStoreServer) DeleteJob(context.Context, *jobmodels.JobFetchDetails) (*jobmodels.Empty, error)
- func (UnimplementedJobStoreServer) GetJob(context.Context, *jobmodels.JobFetchDetails) (*jobmodels.JobCreationDetails, error)
- func (UnimplementedJobStoreServer) ReplicateDeleteJob(context.Context, *jobmodels.JobFetchDetails) (*jobmodels.Empty, error)
- func (UnimplementedJobStoreServer) ReplicateSetJob(context.Context, *jobmodels.JobCreationDetails) (*jobmodels.JobCreationDetails, error)
- func (UnimplementedJobStoreServer) SetJob(context.Context, *jobmodels.JobCreationDetails) (*jobmodels.JobCreationDetails, error)
- type UnsafeJobStoreServer
Constants ¶
const ( JobStore_GetJob_FullMethodName = "/network.JobStore/GetJob" JobStore_SetJob_FullMethodName = "/network.JobStore/SetJob" JobStore_DeleteJob_FullMethodName = "/network.JobStore/DeleteJob" JobStore_ReplicateSetJob_FullMethodName = "/network.JobStore/ReplicateSetJob" JobStore_ReplicateDeleteJob_FullMethodName = "/network.JobStore/ReplicateDeleteJob" )
Variables ¶
var File_components_network_network_proto protoreflect.FileDescriptor
var JobStore_ServiceDesc = grpc.ServiceDesc{ ServiceName: "network.JobStore", HandlerType: (*JobStoreServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetJob", Handler: _JobStore_GetJob_Handler, }, { MethodName: "SetJob", Handler: _JobStore_SetJob_Handler, }, { MethodName: "DeleteJob", Handler: _JobStore_DeleteJob_Handler, }, { MethodName: "ReplicateSetJob", Handler: _JobStore_ReplicateSetJob_Handler, }, { MethodName: "ReplicateDeleteJob", Handler: _JobStore_ReplicateDeleteJob_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "components/network/network.proto", }
JobStore_ServiceDesc is the grpc.ServiceDesc for JobStore service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func CreateJobStoreClient ¶
func CreateJobStoreClient(conn *grpc.ClientConn, rpcTimeout time.Duration) *networkHandler
func RegisterJobStoreServer ¶
func RegisterJobStoreServer(s grpc.ServiceRegistrar, srv JobStoreServer)
Types ¶
type JobStoreClient ¶
type JobStoreClient interface { // GetJob fetches the job from a time machine instance GetJob(ctx context.Context, in *jobmodels.JobFetchDetails, opts ...grpc.CallOption) (*jobmodels.JobCreationDetails, error) // SetJob adds the job to a time machine instance SetJob(ctx context.Context, in *jobmodels.JobCreationDetails, opts ...grpc.CallOption) (*jobmodels.JobCreationDetails, error) // DeleteJob will remove the job from time machine instance DeleteJob(ctx context.Context, in *jobmodels.JobFetchDetails, opts ...grpc.CallOption) (*jobmodels.Empty, error) // ReplicateSetJob is the same as SetJob. It is called only by the leader to replicate the job on the follower ReplicateSetJob(ctx context.Context, in *jobmodels.JobCreationDetails, opts ...grpc.CallOption) (*jobmodels.JobCreationDetails, error) // ReplicateDeleteJob is the same as DeleteJobJob. It is called only by the leader to replicate the job on the follower ReplicateDeleteJob(ctx context.Context, in *jobmodels.JobFetchDetails, opts ...grpc.CallOption) (*jobmodels.Empty, error) }
JobStoreClient is the client API for JobStore 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 NewJobStoreClient ¶
func NewJobStoreClient(cc grpc.ClientConnInterface) JobStoreClient
type JobStoreServer ¶
type JobStoreServer interface { // GetJob fetches the job from a time machine instance GetJob(context.Context, *jobmodels.JobFetchDetails) (*jobmodels.JobCreationDetails, error) // SetJob adds the job to a time machine instance SetJob(context.Context, *jobmodels.JobCreationDetails) (*jobmodels.JobCreationDetails, error) // DeleteJob will remove the job from time machine instance DeleteJob(context.Context, *jobmodels.JobFetchDetails) (*jobmodels.Empty, error) // ReplicateSetJob is the same as SetJob. It is called only by the leader to replicate the job on the follower ReplicateSetJob(context.Context, *jobmodels.JobCreationDetails) (*jobmodels.JobCreationDetails, error) // ReplicateDeleteJob is the same as DeleteJobJob. It is called only by the leader to replicate the job on the follower ReplicateDeleteJob(context.Context, *jobmodels.JobFetchDetails) (*jobmodels.Empty, error) // contains filtered or unexported methods }
JobStoreServer is the server API for JobStore service. All implementations must embed UnimplementedJobStoreServer for forward compatibility
type UnimplementedJobStoreServer ¶
type UnimplementedJobStoreServer struct { }
UnimplementedJobStoreServer must be embedded to have forward compatible implementations.
func (UnimplementedJobStoreServer) DeleteJob ¶
func (UnimplementedJobStoreServer) DeleteJob(context.Context, *jobmodels.JobFetchDetails) (*jobmodels.Empty, error)
func (UnimplementedJobStoreServer) GetJob ¶
func (UnimplementedJobStoreServer) GetJob(context.Context, *jobmodels.JobFetchDetails) (*jobmodels.JobCreationDetails, error)
func (UnimplementedJobStoreServer) ReplicateDeleteJob ¶
func (UnimplementedJobStoreServer) ReplicateDeleteJob(context.Context, *jobmodels.JobFetchDetails) (*jobmodels.Empty, error)
func (UnimplementedJobStoreServer) ReplicateSetJob ¶
func (UnimplementedJobStoreServer) ReplicateSetJob(context.Context, *jobmodels.JobCreationDetails) (*jobmodels.JobCreationDetails, error)
func (UnimplementedJobStoreServer) SetJob ¶
func (UnimplementedJobStoreServer) SetJob(context.Context, *jobmodels.JobCreationDetails) (*jobmodels.JobCreationDetails, error)
type UnsafeJobStoreServer ¶
type UnsafeJobStoreServer interface {
// contains filtered or unexported methods
}
UnsafeJobStoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobStoreServer will result in compilation errors.