gravity_api_controller

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 11, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterControllerServer 

func RegisterControllerServer(s *grpc.Server, srv ControllerServer)

Types

type ControllerClient 

type ControllerClient interface {
	GetClientCount(ctx context.Context, in *GetClientCountRequest, opts ...grpc.CallOption) (*GetClientCountReply, error)
	GetPipelineCount(ctx context.Context, in *GetPipelineCountRequest, opts ...grpc.CallOption) (*GetPipelineCountReply, error)
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterReply, error)
	Unregister(ctx context.Context, in *UnregisterRequest, opts ...grpc.CallOption) (*UnregisterReply, error)
	ReleasePipelines(ctx context.Context, in *ReleasePipelinesRequest, opts ...grpc.CallOption) (*ReleasePipelinesReply, error)
	GetPipelines(ctx context.Context, in *GetPipelinesRequest, opts ...grpc.CallOption) (*GetPipelinesReply, error)
}

ControllerClient is the client API for Controller service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControllerClient 

func NewControllerClient(cc *grpc.ClientConn) ControllerClient

type ControllerServer 

type ControllerServer interface {
	GetClientCount(context.Context, *GetClientCountRequest) (*GetClientCountReply, error)
	GetPipelineCount(context.Context, *GetPipelineCountRequest) (*GetPipelineCountReply, error)
	Register(context.Context, *RegisterRequest) (*RegisterReply, error)
	Unregister(context.Context, *UnregisterRequest) (*UnregisterReply, error)
	ReleasePipelines(context.Context, *ReleasePipelinesRequest) (*ReleasePipelinesReply, error)
	GetPipelines(context.Context, *GetPipelinesRequest) (*GetPipelinesReply, error)
}

ControllerServer is the server API for Controller service.

type GetClientCountReply 

type GetClientCountReply struct {
	Count                uint64   `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetClientCountReply) Descriptor 

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

func (*GetClientCountReply) GetCount 

func (m *GetClientCountReply) GetCount() uint64

func (*GetClientCountReply) ProtoMessage 

func (*GetClientCountReply) ProtoMessage()

func (*GetClientCountReply) Reset 

func (m *GetClientCountReply) Reset()

func (*GetClientCountReply) String 

func (m *GetClientCountReply) String() string

func (*GetClientCountReply) XXX_DiscardUnknown 

func (m *GetClientCountReply) XXX_DiscardUnknown()

func (*GetClientCountReply) XXX_Marshal 

func (m *GetClientCountReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClientCountReply) XXX_Merge 

func (m *GetClientCountReply) XXX_Merge(src proto.Message)

func (*GetClientCountReply) XXX_Size 

func (m *GetClientCountReply) XXX_Size() int

func (*GetClientCountReply) XXX_Unmarshal 

func (m *GetClientCountReply) XXX_Unmarshal(b []byte) error

type GetClientCountRequest 

type GetClientCountRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetClientCountRequest) Descriptor 

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

func (*GetClientCountRequest) ProtoMessage 

func (*GetClientCountRequest) ProtoMessage()

func (*GetClientCountRequest) Reset 

func (m *GetClientCountRequest) Reset()

func (*GetClientCountRequest) String 

func (m *GetClientCountRequest) String() string

func (*GetClientCountRequest) XXX_DiscardUnknown 

func (m *GetClientCountRequest) XXX_DiscardUnknown()

func (*GetClientCountRequest) XXX_Marshal 

func (m *GetClientCountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClientCountRequest) XXX_Merge 

func (m *GetClientCountRequest) XXX_Merge(src proto.Message)

func (*GetClientCountRequest) XXX_Size 

func (m *GetClientCountRequest) XXX_Size() int

func (*GetClientCountRequest) XXX_Unmarshal 

func (m *GetClientCountRequest) XXX_Unmarshal(b []byte) error

type GetPipelineCountReply 

type GetPipelineCountReply struct {
	Count                uint64   `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPipelineCountReply) Descriptor 

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

func (*GetPipelineCountReply) GetCount 

func (m *GetPipelineCountReply) GetCount() uint64

func (*GetPipelineCountReply) ProtoMessage 

func (*GetPipelineCountReply) ProtoMessage()

func (*GetPipelineCountReply) Reset 

func (m *GetPipelineCountReply) Reset()

func (*GetPipelineCountReply) String 

func (m *GetPipelineCountReply) String() string

func (*GetPipelineCountReply) XXX_DiscardUnknown 

func (m *GetPipelineCountReply) XXX_DiscardUnknown()

func (*GetPipelineCountReply) XXX_Marshal 

func (m *GetPipelineCountReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPipelineCountReply) XXX_Merge 

func (m *GetPipelineCountReply) XXX_Merge(src proto.Message)

func (*GetPipelineCountReply) XXX_Size 

func (m *GetPipelineCountReply) XXX_Size() int

func (*GetPipelineCountReply) XXX_Unmarshal 

func (m *GetPipelineCountReply) XXX_Unmarshal(b []byte) error

type GetPipelineCountRequest 

type GetPipelineCountRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPipelineCountRequest) Descriptor 

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

func (*GetPipelineCountRequest) ProtoMessage 

func (*GetPipelineCountRequest) ProtoMessage()

func (*GetPipelineCountRequest) Reset 

func (m *GetPipelineCountRequest) Reset()

func (*GetPipelineCountRequest) String 

func (m *GetPipelineCountRequest) String() string

func (*GetPipelineCountRequest) XXX_DiscardUnknown 

func (m *GetPipelineCountRequest) XXX_DiscardUnknown()

func (*GetPipelineCountRequest) XXX_Marshal 

func (m *GetPipelineCountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPipelineCountRequest) XXX_Merge 

func (m *GetPipelineCountRequest) XXX_Merge(src proto.Message)

func (*GetPipelineCountRequest) XXX_Size 

func (m *GetPipelineCountRequest) XXX_Size() int

func (*GetPipelineCountRequest) XXX_Unmarshal 

func (m *GetPipelineCountRequest) XXX_Unmarshal(b []byte) error

type GetPipelinesReply 

type GetPipelinesReply struct {
	Pipelines            []uint64 `protobuf:"varint,1,rep,packed,name=pipelines,proto3" json:"pipelines,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPipelinesReply) Descriptor 

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

func (*GetPipelinesReply) GetPipelines 

func (m *GetPipelinesReply) GetPipelines() []uint64

func (*GetPipelinesReply) ProtoMessage 

func (*GetPipelinesReply) ProtoMessage()

func (*GetPipelinesReply) Reset 

func (m *GetPipelinesReply) Reset()

func (*GetPipelinesReply) String 

func (m *GetPipelinesReply) String() string

func (*GetPipelinesReply) XXX_DiscardUnknown 

func (m *GetPipelinesReply) XXX_DiscardUnknown()

func (*GetPipelinesReply) XXX_Marshal 

func (m *GetPipelinesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPipelinesReply) XXX_Merge 

func (m *GetPipelinesReply) XXX_Merge(src proto.Message)

func (*GetPipelinesReply) XXX_Size 

func (m *GetPipelinesReply) XXX_Size() int

func (*GetPipelinesReply) XXX_Unmarshal 

func (m *GetPipelinesReply) XXX_Unmarshal(b []byte) error

type GetPipelinesRequest 

type GetPipelinesRequest struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPipelinesRequest) Descriptor 

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

func (*GetPipelinesRequest) GetClientID 

func (m *GetPipelinesRequest) GetClientID() string

func (*GetPipelinesRequest) ProtoMessage 

func (*GetPipelinesRequest) ProtoMessage()

func (*GetPipelinesRequest) Reset 

func (m *GetPipelinesRequest) Reset()

func (*GetPipelinesRequest) String 

func (m *GetPipelinesRequest) String() string

func (*GetPipelinesRequest) XXX_DiscardUnknown 

func (m *GetPipelinesRequest) XXX_DiscardUnknown()

func (*GetPipelinesRequest) XXX_Marshal 

func (m *GetPipelinesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPipelinesRequest) XXX_Merge 

func (m *GetPipelinesRequest) XXX_Merge(src proto.Message)

func (*GetPipelinesRequest) XXX_Size 

func (m *GetPipelinesRequest) XXX_Size() int

func (*GetPipelinesRequest) XXX_Unmarshal 

func (m *GetPipelinesRequest) XXX_Unmarshal(b []byte) error

type RegisterReply 

type RegisterReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterReply) Descriptor 

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

func (*RegisterReply) GetReason 

func (m *RegisterReply) GetReason() string

func (*RegisterReply) GetSuccess 

func (m *RegisterReply) GetSuccess() bool

func (*RegisterReply) ProtoMessage 

func (*RegisterReply) ProtoMessage()

func (*RegisterReply) Reset 

func (m *RegisterReply) Reset()

func (*RegisterReply) String 

func (m *RegisterReply) String() string

func (*RegisterReply) XXX_DiscardUnknown 

func (m *RegisterReply) XXX_DiscardUnknown()

func (*RegisterReply) XXX_Marshal 

func (m *RegisterReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterReply) XXX_Merge 

func (m *RegisterReply) XXX_Merge(src proto.Message)

func (*RegisterReply) XXX_Size 

func (m *RegisterReply) XXX_Size() int

func (*RegisterReply) XXX_Unmarshal 

func (m *RegisterReply) XXX_Unmarshal(b []byte) error

type RegisterRequest 

type RegisterRequest struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) GetClientID 

func (m *RegisterRequest) GetClientID() string

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

func (*RegisterRequest) XXX_DiscardUnknown 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal 

func (m *RegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterRequest) XXX_Merge 

func (m *RegisterRequest) XXX_Merge(src proto.Message)

func (*RegisterRequest) XXX_Size 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal 

func (m *RegisterRequest) XXX_Unmarshal(b []byte) error

type ReleasePipelinesReply 

type ReleasePipelinesReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Failures             []uint64 `protobuf:"varint,3,rep,packed,name=failures,proto3" json:"failures,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReleasePipelinesReply) Descriptor 

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

func (*ReleasePipelinesReply) GetFailures 

func (m *ReleasePipelinesReply) GetFailures() []uint64

func (*ReleasePipelinesReply) GetReason 

func (m *ReleasePipelinesReply) GetReason() string

func (*ReleasePipelinesReply) GetSuccess 

func (m *ReleasePipelinesReply) GetSuccess() bool

func (*ReleasePipelinesReply) ProtoMessage 

func (*ReleasePipelinesReply) ProtoMessage()

func (*ReleasePipelinesReply) Reset 

func (m *ReleasePipelinesReply) Reset()

func (*ReleasePipelinesReply) String 

func (m *ReleasePipelinesReply) String() string

func (*ReleasePipelinesReply) XXX_DiscardUnknown 

func (m *ReleasePipelinesReply) XXX_DiscardUnknown()

func (*ReleasePipelinesReply) XXX_Marshal 

func (m *ReleasePipelinesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReleasePipelinesReply) XXX_Merge 

func (m *ReleasePipelinesReply) XXX_Merge(src proto.Message)

func (*ReleasePipelinesReply) XXX_Size 

func (m *ReleasePipelinesReply) XXX_Size() int

func (*ReleasePipelinesReply) XXX_Unmarshal 

func (m *ReleasePipelinesReply) XXX_Unmarshal(b []byte) error

type ReleasePipelinesRequest 

type ReleasePipelinesRequest struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	Pipelines            []uint64 `protobuf:"varint,2,rep,packed,name=pipelines,proto3" json:"pipelines,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReleasePipelinesRequest) Descriptor 

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

func (*ReleasePipelinesRequest) GetClientID 

func (m *ReleasePipelinesRequest) GetClientID() string

func (*ReleasePipelinesRequest) GetPipelines 

func (m *ReleasePipelinesRequest) GetPipelines() []uint64

func (*ReleasePipelinesRequest) ProtoMessage 

func (*ReleasePipelinesRequest) ProtoMessage()

func (*ReleasePipelinesRequest) Reset 

func (m *ReleasePipelinesRequest) Reset()

func (*ReleasePipelinesRequest) String 

func (m *ReleasePipelinesRequest) String() string

func (*ReleasePipelinesRequest) XXX_DiscardUnknown 

func (m *ReleasePipelinesRequest) XXX_DiscardUnknown()

func (*ReleasePipelinesRequest) XXX_Marshal 

func (m *ReleasePipelinesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReleasePipelinesRequest) XXX_Merge 

func (m *ReleasePipelinesRequest) XXX_Merge(src proto.Message)

func (*ReleasePipelinesRequest) XXX_Size 

func (m *ReleasePipelinesRequest) XXX_Size() int

func (*ReleasePipelinesRequest) XXX_Unmarshal 

func (m *ReleasePipelinesRequest) XXX_Unmarshal(b []byte) error

type UnimplementedControllerServer 

type UnimplementedControllerServer struct {
}

UnimplementedControllerServer can be embedded to have forward compatible implementations.

func (*UnimplementedControllerServer) GetClientCount 

func (*UnimplementedControllerServer) GetClientCount(ctx context.Context, req *GetClientCountRequest) (*GetClientCountReply, error)

func (*UnimplementedControllerServer) GetPipelineCount 

func (*UnimplementedControllerServer) GetPipelineCount(ctx context.Context, req *GetPipelineCountRequest) (*GetPipelineCountReply, error)

func (*UnimplementedControllerServer) GetPipelines 

func (*UnimplementedControllerServer) GetPipelines(ctx context.Context, req *GetPipelinesRequest) (*GetPipelinesReply, error)

func (*UnimplementedControllerServer) Register 

func (*UnimplementedControllerServer) Register(ctx context.Context, req *RegisterRequest) (*RegisterReply, error)

func (*UnimplementedControllerServer) ReleasePipelines 

func (*UnimplementedControllerServer) ReleasePipelines(ctx context.Context, req *ReleasePipelinesRequest) (*ReleasePipelinesReply, error)

func (*UnimplementedControllerServer) Unregister 

func (*UnimplementedControllerServer) Unregister(ctx context.Context, req *UnregisterRequest) (*UnregisterReply, error)

type UnregisterReply 

type UnregisterReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnregisterReply) Descriptor 

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

func (*UnregisterReply) GetReason 

func (m *UnregisterReply) GetReason() string

func (*UnregisterReply) GetSuccess 

func (m *UnregisterReply) GetSuccess() bool

func (*UnregisterReply) ProtoMessage 

func (*UnregisterReply) ProtoMessage()

func (*UnregisterReply) Reset 

func (m *UnregisterReply) Reset()

func (*UnregisterReply) String 

func (m *UnregisterReply) String() string

func (*UnregisterReply) XXX_DiscardUnknown 

func (m *UnregisterReply) XXX_DiscardUnknown()

func (*UnregisterReply) XXX_Marshal 

func (m *UnregisterReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnregisterReply) XXX_Merge 

func (m *UnregisterReply) XXX_Merge(src proto.Message)

func (*UnregisterReply) XXX_Size 

func (m *UnregisterReply) XXX_Size() int

func (*UnregisterReply) XXX_Unmarshal 

func (m *UnregisterReply) XXX_Unmarshal(b []byte) error

type UnregisterRequest 

type UnregisterRequest struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnregisterRequest) Descriptor 

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

func (*UnregisterRequest) GetClientID 

func (m *UnregisterRequest) GetClientID() string

func (*UnregisterRequest) ProtoMessage 

func (*UnregisterRequest) ProtoMessage()

func (*UnregisterRequest) Reset 

func (m *UnregisterRequest) Reset()

func (*UnregisterRequest) String 

func (m *UnregisterRequest) String() string

func (*UnregisterRequest) XXX_DiscardUnknown 

func (m *UnregisterRequest) XXX_DiscardUnknown()

func (*UnregisterRequest) XXX_Marshal 

func (m *UnregisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnregisterRequest) XXX_Merge 

func (m *UnregisterRequest) XXX_Merge(src proto.Message)

func (*UnregisterRequest) XXX_Size 

func (m *UnregisterRequest) XXX_Size() int

func (*UnregisterRequest) XXX_Unmarshal 

func (m *UnregisterRequest) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.