proto

Documentation

Index

• Variables
• func RegisterFeedsManagerServer(s wsrpc.ServiceRegistrar, srv FeedsManagerServer)
• func RegisterNodeServiceServer(s wsrpc.ServiceRegistrar, srv NodeServiceServer)
• type ApproveJobRequest
  • func (*ApproveJobRequest) Descriptor() ([]byte, []int)
  • func (x *ApproveJobRequest) GetId() string
  • func (*ApproveJobRequest) ProtoMessage()
  • func (x *ApproveJobRequest) ProtoReflect() protoreflect.Message
  • func (x *ApproveJobRequest) Reset()
  • func (x *ApproveJobRequest) String() string
• type ApproveJobResponse
  • func (*ApproveJobResponse) Descriptor() ([]byte, []int)
  • func (*ApproveJobResponse) ProtoMessage()
  • func (x *ApproveJobResponse) ProtoReflect() protoreflect.Message
  • func (x *ApproveJobResponse) Reset()
  • func (x *ApproveJobResponse) String() string
• type FeedsManagerClient
  • func NewFeedsManagerClient(cc wsrpc.ClientInterface) FeedsManagerClient
• type FeedsManagerServer
• type NodeServiceClient
  • func NewNodeServiceClient(cc wsrpc.ClientInterface) NodeServiceClient
• type NodeServiceServer
• type ProposeJobRequest
  • func (*ProposeJobRequest) Descriptor() ([]byte, []int)
  • func (x *ProposeJobRequest) GetId() string
  • func (x *ProposeJobRequest) GetSpec() string
  • func (*ProposeJobRequest) ProtoMessage()
  • func (x *ProposeJobRequest) ProtoReflect() protoreflect.Message
  • func (x *ProposeJobRequest) Reset()
  • func (x *ProposeJobRequest) String() string
• type ProposeJobResponse
  • func (*ProposeJobResponse) Descriptor() ([]byte, []int)
  • func (x *ProposeJobResponse) GetId() string
  • func (*ProposeJobResponse) ProtoMessage()
  • func (x *ProposeJobResponse) ProtoReflect() protoreflect.Message
  • func (x *ProposeJobResponse) Reset()
  • func (x *ProposeJobResponse) String() string

Variables

var FeedsManager_ServiceDesc = wsrpc.ServiceDesc{
	ServiceName: "cfm.FeedsManager",
	HandlerType: (*FeedsManagerServer)(nil),
	Methods: []wsrpc.MethodDesc{
		{
			MethodName: "ApproveJob",
			Handler:    _FeedsManager_ApproveJob_Handler,
		},
	},
}

FeedsManager_ServiceDesc is the wsrpc.ServiceDesc for FeedsManager service. It's only intended for direct use with wsrpc.RegisterService, and not to be introspected or modified (even as a copy)

var File_feeds_manager_proto protoreflect.FileDescriptor

var NodeService_ServiceDesc = wsrpc.ServiceDesc{
	ServiceName: "cfm.NodeService",
	HandlerType: (*NodeServiceServer)(nil),
	Methods: []wsrpc.MethodDesc{
		{
			MethodName: "ProposeJob",
			Handler:    _NodeService_ProposeJob_Handler,
		},
	},
}

NodeService_ServiceDesc is the wsrpc.ServiceDesc for NodeService service. It's only intended for direct use with wsrpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFeedsManagerServer

func RegisterFeedsManagerServer(s wsrpc.ServiceRegistrar, srv FeedsManagerServer)

func RegisterNodeServiceServer

func RegisterNodeServiceServer(s wsrpc.ServiceRegistrar, srv NodeServiceServer)

Types

type ApproveJobRequest

type ApproveJobRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ApproveJobRequest) Descriptor

func (*ApproveJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use ApproveJobRequest.ProtoReflect.Descriptor instead.

func (*ApproveJobRequest) GetId

func (x *ApproveJobRequest) GetId() string

func (*ApproveJobRequest) ProtoMessage

func (*ApproveJobRequest) ProtoMessage()

func (*ApproveJobRequest) ProtoReflect

func (x *ApproveJobRequest) ProtoReflect() protoreflect.Message

func (*ApproveJobRequest) Reset

func (x *ApproveJobRequest) Reset()

func (*ApproveJobRequest) String

func (x *ApproveJobRequest) String() string

type ApproveJobResponse

type ApproveJobResponse struct {
	// contains filtered or unexported fields
}

func (*ApproveJobResponse) Descriptor

func (*ApproveJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use ApproveJobResponse.ProtoReflect.Descriptor instead.

func (*ApproveJobResponse) ProtoMessage

func (*ApproveJobResponse) ProtoMessage()

func (*ApproveJobResponse) ProtoReflect

func (x *ApproveJobResponse) ProtoReflect() protoreflect.Message

func (*ApproveJobResponse) Reset

func (x *ApproveJobResponse) Reset()

func (*ApproveJobResponse) String

func (x *ApproveJobResponse) String() string

type FeedsManagerClient

type FeedsManagerClient interface {
	ApproveJob(ctx context.Context, in *ApproveJobRequest) (*ApproveJobResponse, error)
}

FeedsManagerClient is the client API for FeedsManager service.

func NewFeedsManagerClient

func NewFeedsManagerClient(cc wsrpc.ClientInterface) FeedsManagerClient

type FeedsManagerServer

type FeedsManagerServer interface {
	ApproveJob(context.Context, *ApproveJobRequest) (*ApproveJobResponse, error)
}

FeedsManagerServer is the server API for FeedsManager service.

type NodeServiceClient

type NodeServiceClient interface {
	ProposeJob(ctx context.Context, in *ProposeJobRequest) (*ProposeJobResponse, error)
}

NodeServiceClient is the client API for NodeService service.

func NewNodeServiceClient

func NewNodeServiceClient(cc wsrpc.ClientInterface) NodeServiceClient

type NodeServiceServer

type NodeServiceServer interface {
	ProposeJob(context.Context, *ProposeJobRequest) (*ProposeJobResponse, error)
}

NodeServiceServer is the server API for NodeService service.

type ProposeJobRequest

type ProposeJobRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Spec string `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*ProposeJobRequest) Descriptor

func (*ProposeJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use ProposeJobRequest.ProtoReflect.Descriptor instead.

func (*ProposeJobRequest) GetId

func (x *ProposeJobRequest) GetId() string

func (*ProposeJobRequest) GetSpec

func (x *ProposeJobRequest) GetSpec() string

func (*ProposeJobRequest) ProtoMessage

func (*ProposeJobRequest) ProtoMessage()

func (*ProposeJobRequest) ProtoReflect

func (x *ProposeJobRequest) ProtoReflect() protoreflect.Message

func (*ProposeJobRequest) Reset

func (x *ProposeJobRequest) Reset()

func (*ProposeJobRequest) String

func (x *ProposeJobRequest) String() string

type ProposeJobResponse

type ProposeJobResponse struct {
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ProposeJobResponse) Descriptor

func (*ProposeJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use ProposeJobResponse.ProtoReflect.Descriptor instead.

func (*ProposeJobResponse) GetId

func (x *ProposeJobResponse) GetId() string

func (*ProposeJobResponse) ProtoMessage

func (*ProposeJobResponse) ProtoMessage()

func (*ProposeJobResponse) ProtoReflect

func (x *ProposeJobResponse) ProtoReflect() protoreflect.Message

func (*ProposeJobResponse) Reset

func (x *ProposeJobResponse) Reset()

func (*ProposeJobResponse) String

func (x *ProposeJobResponse) String() string