Documentation
¶
Overview ¶
Package protocol is a generated protocol buffer package.
It is generated from these files:
github.com/bblfsh/bblfshd/daemon/protocol/generated.proto
It has these top-level messages:
DriverImageState DriverInstanceState DriverInstanceStatesResponse DriverPoolState DriverPoolStatesResponse DriverStatesResponse InstallDriverRequest RemoveDriverRequest Response DriverInstanceStatesRequest DriverPoolStatesRequest DriverStatesRequest
Index ¶
- Variables
- func RegisterProtocolServiceServer(s *grpc.Server, srv ProtocolServiceServer)
- func RegisterService(srv *grpc.Server, s Service)
- type DriverImageState
- func (*DriverImageState) Descriptor() ([]byte, []int)
- func (m *DriverImageState) Marshal() (dAtA []byte, err error)
- func (m *DriverImageState) MarshalTo(dAtA []byte) (int, error)
- func (*DriverImageState) ProtoMessage()
- func (m *DriverImageState) ProtoSize() (n int)
- func (m *DriverImageState) Reset()
- func (m *DriverImageState) String() string
- func (m *DriverImageState) Unmarshal(dAtA []byte) error
- type DriverInstanceState
- func (*DriverInstanceState) Descriptor() ([]byte, []int)
- func (m *DriverInstanceState) Marshal() (dAtA []byte, err error)
- func (m *DriverInstanceState) MarshalTo(dAtA []byte) (int, error)
- func (*DriverInstanceState) ProtoMessage()
- func (m *DriverInstanceState) ProtoSize() (n int)
- func (m *DriverInstanceState) Reset()
- func (m *DriverInstanceState) String() string
- func (m *DriverInstanceState) Unmarshal(dAtA []byte) error
- type DriverInstanceStatesRequest
- func (*DriverInstanceStatesRequest) Descriptor() ([]byte, []int)
- func (m *DriverInstanceStatesRequest) Marshal() (dAtA []byte, err error)
- func (m *DriverInstanceStatesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DriverInstanceStatesRequest) ProtoMessage()
- func (m *DriverInstanceStatesRequest) ProtoSize() (n int)
- func (m *DriverInstanceStatesRequest) Reset()
- func (m *DriverInstanceStatesRequest) String() string
- func (m *DriverInstanceStatesRequest) Unmarshal(dAtA []byte) error
- type DriverInstanceStatesResponse
- func (*DriverInstanceStatesResponse) Descriptor() ([]byte, []int)
- func (m *DriverInstanceStatesResponse) Marshal() (dAtA []byte, err error)
- func (m *DriverInstanceStatesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DriverInstanceStatesResponse) ProtoMessage()
- func (m *DriverInstanceStatesResponse) ProtoSize() (n int)
- func (m *DriverInstanceStatesResponse) Reset()
- func (m *DriverInstanceStatesResponse) String() string
- func (m *DriverInstanceStatesResponse) Unmarshal(dAtA []byte) error
- type DriverPoolState
- func (*DriverPoolState) Descriptor() ([]byte, []int)
- func (m *DriverPoolState) Marshal() (dAtA []byte, err error)
- func (m *DriverPoolState) MarshalTo(dAtA []byte) (int, error)
- func (*DriverPoolState) ProtoMessage()
- func (m *DriverPoolState) ProtoSize() (n int)
- func (m *DriverPoolState) Reset()
- func (m *DriverPoolState) String() string
- func (m *DriverPoolState) Unmarshal(dAtA []byte) error
- type DriverPoolStatesRequest
- func (*DriverPoolStatesRequest) Descriptor() ([]byte, []int)
- func (m *DriverPoolStatesRequest) Marshal() (dAtA []byte, err error)
- func (m *DriverPoolStatesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DriverPoolStatesRequest) ProtoMessage()
- func (m *DriverPoolStatesRequest) ProtoSize() (n int)
- func (m *DriverPoolStatesRequest) Reset()
- func (m *DriverPoolStatesRequest) String() string
- func (m *DriverPoolStatesRequest) Unmarshal(dAtA []byte) error
- type DriverPoolStatesResponse
- func (*DriverPoolStatesResponse) Descriptor() ([]byte, []int)
- func (m *DriverPoolStatesResponse) Marshal() (dAtA []byte, err error)
- func (m *DriverPoolStatesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DriverPoolStatesResponse) ProtoMessage()
- func (m *DriverPoolStatesResponse) ProtoSize() (n int)
- func (m *DriverPoolStatesResponse) Reset()
- func (m *DriverPoolStatesResponse) String() string
- func (m *DriverPoolStatesResponse) Unmarshal(dAtA []byte) error
- type DriverStatesRequest
- func (*DriverStatesRequest) Descriptor() ([]byte, []int)
- func (m *DriverStatesRequest) Marshal() (dAtA []byte, err error)
- func (m *DriverStatesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DriverStatesRequest) ProtoMessage()
- func (m *DriverStatesRequest) ProtoSize() (n int)
- func (m *DriverStatesRequest) Reset()
- func (m *DriverStatesRequest) String() string
- func (m *DriverStatesRequest) Unmarshal(dAtA []byte) error
- type DriverStatesResponse
- func (*DriverStatesResponse) Descriptor() ([]byte, []int)
- func (m *DriverStatesResponse) Marshal() (dAtA []byte, err error)
- func (m *DriverStatesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*DriverStatesResponse) ProtoMessage()
- func (m *DriverStatesResponse) ProtoSize() (n int)
- func (m *DriverStatesResponse) Reset()
- func (m *DriverStatesResponse) String() string
- func (m *DriverStatesResponse) Unmarshal(dAtA []byte) error
- type InstallDriverRequest
- func (*InstallDriverRequest) Descriptor() ([]byte, []int)
- func (m *InstallDriverRequest) Marshal() (dAtA []byte, err error)
- func (m *InstallDriverRequest) MarshalTo(dAtA []byte) (int, error)
- func (*InstallDriverRequest) ProtoMessage()
- func (m *InstallDriverRequest) ProtoSize() (n int)
- func (m *InstallDriverRequest) Reset()
- func (m *InstallDriverRequest) String() string
- func (m *InstallDriverRequest) Unmarshal(dAtA []byte) error
- type ProtocolServiceClient
- type ProtocolServiceServer
- type RemoveDriverRequest
- func (*RemoveDriverRequest) Descriptor() ([]byte, []int)
- func (m *RemoveDriverRequest) Marshal() (dAtA []byte, err error)
- func (m *RemoveDriverRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveDriverRequest) ProtoMessage()
- func (m *RemoveDriverRequest) ProtoSize() (n int)
- func (m *RemoveDriverRequest) Reset()
- func (m *RemoveDriverRequest) String() string
- func (m *RemoveDriverRequest) Unmarshal(dAtA []byte) error
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) Marshal() (dAtA []byte, err error)
- func (m *Response) MarshalTo(dAtA []byte) (int, error)
- func (*Response) ProtoMessage()
- func (m *Response) ProtoSize() (n int)
- func (m *Response) Reset()
- func (m *Response) String() string
- func (m *Response) Unmarshal(dAtA []byte) error
- type Service
- type Status
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow") )
View Source
var (
ErrAlreadyInstalled = errors.NewKind("driver already installed: %s (image reference: %s)")
)
View Source
var Status_name = map[int32]string{
0: "CREATED",
1: "RUNNING",
2: "PAUSING",
3: "PAUSED",
4: "STOPPED",
}
Status is the status of a driver instance.
View Source
var Status_value = map[string]int32{
"CREATED": 0,
"RUNNING": 1,
"PAUSING": 2,
"PAUSED": 3,
"STOPPED": 4,
}
Functions ¶
func RegisterProtocolServiceServer ¶
func RegisterProtocolServiceServer(s *grpc.Server, srv ProtocolServiceServer)
func RegisterService ¶
Types ¶
type DriverImageState ¶
type DriverImageState struct {
// Referene is the image reference from where retrieved.
Reference string `json:"reference"`
// This fields are from manifest.Manifest, due to some limitation of
// proteus, can't be used directly.
// Language of the driver.
Language string `json:"language"`
// Version of the driver.
Version string `json:"version,omitempty"`
// Build time at the compilation of the image.
Build time.Time `json:"build,omitempty"`
// Status is the development status of the driver (alpha, beta, etc)
Status string `json:"status"`
// OS is the linux distribution running on the driver container.
OS string `json:"os"`
// Native version is the version of the compiler/interpreter being use in the
// native side of the driver.
NativeVersion []string `json:"native_version"`
// Go version of the go runtime being use in the driver.
GoVersion string `json:"go_version"`
}
func (*DriverImageState) Descriptor ¶
func (*DriverImageState) Descriptor() ([]byte, []int)
func (*DriverImageState) Marshal ¶
func (m *DriverImageState) Marshal() (dAtA []byte, err error)
func (*DriverImageState) ProtoMessage ¶
func (*DriverImageState) ProtoMessage()
func (*DriverImageState) ProtoSize ¶
func (m *DriverImageState) ProtoSize() (n int)
func (*DriverImageState) Reset ¶
func (m *DriverImageState) Reset()
func (*DriverImageState) String ¶
func (m *DriverImageState) String() string
func (*DriverImageState) Unmarshal ¶
func (m *DriverImageState) Unmarshal(dAtA []byte) error
type DriverInstanceState ¶
type DriverInstanceState struct {
// ID of the container executing the driver.
ID string `json:"id"`
// Image used by the container.
Image string
// Status current status of the driver.
Status Status `json:"status"`
// Create when the driver instances was created.
Created time.Time `json:"created"`
// Processes are the pids of the processes running inside of the container.
Processes []int `json:"processes"`
}
func (*DriverInstanceState) Descriptor ¶
func (*DriverInstanceState) Descriptor() ([]byte, []int)
func (*DriverInstanceState) Marshal ¶
func (m *DriverInstanceState) Marshal() (dAtA []byte, err error)
func (*DriverInstanceState) MarshalTo ¶
func (m *DriverInstanceState) MarshalTo(dAtA []byte) (int, error)
func (*DriverInstanceState) ProtoMessage ¶
func (*DriverInstanceState) ProtoMessage()
func (*DriverInstanceState) ProtoSize ¶
func (m *DriverInstanceState) ProtoSize() (n int)
func (*DriverInstanceState) Reset ¶
func (m *DriverInstanceState) Reset()
func (*DriverInstanceState) String ¶
func (m *DriverInstanceState) String() string
func (*DriverInstanceState) Unmarshal ¶
func (m *DriverInstanceState) Unmarshal(dAtA []byte) error
type DriverInstanceStatesRequest ¶
type DriverInstanceStatesRequest struct {
}
func (*DriverInstanceStatesRequest) Descriptor ¶
func (*DriverInstanceStatesRequest) Descriptor() ([]byte, []int)
func (*DriverInstanceStatesRequest) Marshal ¶
func (m *DriverInstanceStatesRequest) Marshal() (dAtA []byte, err error)
func (*DriverInstanceStatesRequest) MarshalTo ¶
func (m *DriverInstanceStatesRequest) MarshalTo(dAtA []byte) (int, error)
func (*DriverInstanceStatesRequest) ProtoMessage ¶
func (*DriverInstanceStatesRequest) ProtoMessage()
func (*DriverInstanceStatesRequest) ProtoSize ¶
func (m *DriverInstanceStatesRequest) ProtoSize() (n int)
func (*DriverInstanceStatesRequest) Reset ¶
func (m *DriverInstanceStatesRequest) Reset()
func (*DriverInstanceStatesRequest) String ¶
func (m *DriverInstanceStatesRequest) String() string
func (*DriverInstanceStatesRequest) Unmarshal ¶
func (m *DriverInstanceStatesRequest) Unmarshal(dAtA []byte) error
type DriverInstanceStatesResponse ¶
type DriverInstanceStatesResponse struct {
protocol.Response
// State represent the state of each driver instance in the daemon.
State []*DriverInstanceState
}
func (*DriverInstanceStatesResponse) Descriptor ¶
func (*DriverInstanceStatesResponse) Descriptor() ([]byte, []int)
func (*DriverInstanceStatesResponse) Marshal ¶
func (m *DriverInstanceStatesResponse) Marshal() (dAtA []byte, err error)
func (*DriverInstanceStatesResponse) MarshalTo ¶
func (m *DriverInstanceStatesResponse) MarshalTo(dAtA []byte) (int, error)
func (*DriverInstanceStatesResponse) ProtoMessage ¶
func (*DriverInstanceStatesResponse) ProtoMessage()
func (*DriverInstanceStatesResponse) ProtoSize ¶
func (m *DriverInstanceStatesResponse) ProtoSize() (n int)
func (*DriverInstanceStatesResponse) Reset ¶
func (m *DriverInstanceStatesResponse) Reset()
func (*DriverInstanceStatesResponse) String ¶
func (m *DriverInstanceStatesResponse) String() string
func (*DriverInstanceStatesResponse) Unmarshal ¶
func (m *DriverInstanceStatesResponse) Unmarshal(dAtA []byte) error
type DriverPoolState ¶
type DriverPoolState struct {
// Instances number of driver instances wanted.
Wanted int `json:"wanted"`
// Running number of driver instances running.
Running int `json:"running"`
// Waiting number of request waiting for a request be executed.
Waiting int `json:"waiting"`
// Success number of requests executed successfully.
Success int `json:"success"`
// Errors number of errors trying to process a request.
Errors int `json:"errors"`
// Exited number of drivers exited unexpectedly.
Exited int `json:"exited"`
}
func (*DriverPoolState) Descriptor ¶
func (*DriverPoolState) Descriptor() ([]byte, []int)
func (*DriverPoolState) Marshal ¶
func (m *DriverPoolState) Marshal() (dAtA []byte, err error)
func (*DriverPoolState) ProtoMessage ¶
func (*DriverPoolState) ProtoMessage()
func (*DriverPoolState) ProtoSize ¶
func (m *DriverPoolState) ProtoSize() (n int)
func (*DriverPoolState) Reset ¶
func (m *DriverPoolState) Reset()
func (*DriverPoolState) String ¶
func (m *DriverPoolState) String() string
func (*DriverPoolState) Unmarshal ¶
func (m *DriverPoolState) Unmarshal(dAtA []byte) error
type DriverPoolStatesRequest ¶
type DriverPoolStatesRequest struct {
}
func (*DriverPoolStatesRequest) Descriptor ¶
func (*DriverPoolStatesRequest) Descriptor() ([]byte, []int)
func (*DriverPoolStatesRequest) Marshal ¶
func (m *DriverPoolStatesRequest) Marshal() (dAtA []byte, err error)
func (*DriverPoolStatesRequest) MarshalTo ¶
func (m *DriverPoolStatesRequest) MarshalTo(dAtA []byte) (int, error)
func (*DriverPoolStatesRequest) ProtoMessage ¶
func (*DriverPoolStatesRequest) ProtoMessage()
func (*DriverPoolStatesRequest) ProtoSize ¶
func (m *DriverPoolStatesRequest) ProtoSize() (n int)
func (*DriverPoolStatesRequest) Reset ¶
func (m *DriverPoolStatesRequest) Reset()
func (*DriverPoolStatesRequest) String ¶
func (m *DriverPoolStatesRequest) String() string
func (*DriverPoolStatesRequest) Unmarshal ¶
func (m *DriverPoolStatesRequest) Unmarshal(dAtA []byte) error
type DriverPoolStatesResponse ¶
type DriverPoolStatesResponse struct {
protocol.Response
// State represent the state of each pool in the daemon.
State map[string]*DriverPoolState
}
func (*DriverPoolStatesResponse) Descriptor ¶
func (*DriverPoolStatesResponse) Descriptor() ([]byte, []int)
func (*DriverPoolStatesResponse) Marshal ¶
func (m *DriverPoolStatesResponse) Marshal() (dAtA []byte, err error)
func (*DriverPoolStatesResponse) MarshalTo ¶
func (m *DriverPoolStatesResponse) MarshalTo(dAtA []byte) (int, error)
func (*DriverPoolStatesResponse) ProtoMessage ¶
func (*DriverPoolStatesResponse) ProtoMessage()
func (*DriverPoolStatesResponse) ProtoSize ¶
func (m *DriverPoolStatesResponse) ProtoSize() (n int)
func (*DriverPoolStatesResponse) Reset ¶
func (m *DriverPoolStatesResponse) Reset()
func (*DriverPoolStatesResponse) String ¶
func (m *DriverPoolStatesResponse) String() string
func (*DriverPoolStatesResponse) Unmarshal ¶
func (m *DriverPoolStatesResponse) Unmarshal(dAtA []byte) error
type DriverStatesRequest ¶
type DriverStatesRequest struct {
}
func (*DriverStatesRequest) Descriptor ¶
func (*DriverStatesRequest) Descriptor() ([]byte, []int)
func (*DriverStatesRequest) Marshal ¶
func (m *DriverStatesRequest) Marshal() (dAtA []byte, err error)
func (*DriverStatesRequest) MarshalTo ¶
func (m *DriverStatesRequest) MarshalTo(dAtA []byte) (int, error)
func (*DriverStatesRequest) ProtoMessage ¶
func (*DriverStatesRequest) ProtoMessage()
func (*DriverStatesRequest) ProtoSize ¶
func (m *DriverStatesRequest) ProtoSize() (n int)
func (*DriverStatesRequest) Reset ¶
func (m *DriverStatesRequest) Reset()
func (*DriverStatesRequest) String ¶
func (m *DriverStatesRequest) String() string
func (*DriverStatesRequest) Unmarshal ¶
func (m *DriverStatesRequest) Unmarshal(dAtA []byte) error
type DriverStatesResponse ¶
type DriverStatesResponse struct {
protocol.Response
// State represent the state of each driver in the storage.
State []*DriverImageState
}
func (*DriverStatesResponse) Descriptor ¶
func (*DriverStatesResponse) Descriptor() ([]byte, []int)
func (*DriverStatesResponse) Marshal ¶
func (m *DriverStatesResponse) Marshal() (dAtA []byte, err error)
func (*DriverStatesResponse) MarshalTo ¶
func (m *DriverStatesResponse) MarshalTo(dAtA []byte) (int, error)
func (*DriverStatesResponse) ProtoMessage ¶
func (*DriverStatesResponse) ProtoMessage()
func (*DriverStatesResponse) ProtoSize ¶
func (m *DriverStatesResponse) ProtoSize() (n int)
func (*DriverStatesResponse) Reset ¶
func (m *DriverStatesResponse) Reset()
func (*DriverStatesResponse) String ¶
func (m *DriverStatesResponse) String() string
func (*DriverStatesResponse) Unmarshal ¶
func (m *DriverStatesResponse) Unmarshal(dAtA []byte) error
type InstallDriverRequest ¶
type InstallDriverRequest struct {
// Language supported by the driver being installed.
Language string
// ImageReference is the name of the image to be installed in the following
// format: `transport:[//]name[:tag]`. The default value for tag is `latest`
ImageReference string
// Update indicates whether an image should be updated. When set to false,
// the installation fails if the image already exists.
Update bool
}
func (*InstallDriverRequest) Descriptor ¶
func (*InstallDriverRequest) Descriptor() ([]byte, []int)
func (*InstallDriverRequest) Marshal ¶
func (m *InstallDriverRequest) Marshal() (dAtA []byte, err error)
func (*InstallDriverRequest) MarshalTo ¶
func (m *InstallDriverRequest) MarshalTo(dAtA []byte) (int, error)
func (*InstallDriverRequest) ProtoMessage ¶
func (*InstallDriverRequest) ProtoMessage()
func (*InstallDriverRequest) ProtoSize ¶
func (m *InstallDriverRequest) ProtoSize() (n int)
func (*InstallDriverRequest) Reset ¶
func (m *InstallDriverRequest) Reset()
func (*InstallDriverRequest) String ¶
func (m *InstallDriverRequest) String() string
func (*InstallDriverRequest) Unmarshal ¶
func (m *InstallDriverRequest) Unmarshal(dAtA []byte) error
type ProtocolServiceClient ¶
type ProtocolServiceClient interface {
DriverInstanceStates(ctx context.Context, in *DriverInstanceStatesRequest, opts ...grpc.CallOption) (*DriverInstanceStatesResponse, error)
DriverPoolStates(ctx context.Context, in *DriverPoolStatesRequest, opts ...grpc.CallOption) (*DriverPoolStatesResponse, error)
DriverStates(ctx context.Context, in *DriverStatesRequest, opts ...grpc.CallOption) (*DriverStatesResponse, error)
InstallDriver(ctx context.Context, in *InstallDriverRequest, opts ...grpc.CallOption) (*Response, error)
RemoveDriver(ctx context.Context, in *RemoveDriverRequest, opts ...grpc.CallOption) (*Response, error)
}
func NewProtocolServiceClient ¶
func NewProtocolServiceClient(cc *grpc.ClientConn) ProtocolServiceClient
type ProtocolServiceServer ¶
type ProtocolServiceServer interface {
DriverInstanceStates(context.Context, *DriverInstanceStatesRequest) (*DriverInstanceStatesResponse, error)
DriverPoolStates(context.Context, *DriverPoolStatesRequest) (*DriverPoolStatesResponse, error)
DriverStates(context.Context, *DriverStatesRequest) (*DriverStatesResponse, error)
InstallDriver(context.Context, *InstallDriverRequest) (*Response, error)
RemoveDriver(context.Context, *RemoveDriverRequest) (*Response, error)
}
type RemoveDriverRequest ¶
type RemoveDriverRequest struct {
// Language supported by the driver to be deleted.
Language string
}
func (*RemoveDriverRequest) Descriptor ¶
func (*RemoveDriverRequest) Descriptor() ([]byte, []int)
func (*RemoveDriverRequest) Marshal ¶
func (m *RemoveDriverRequest) Marshal() (dAtA []byte, err error)
func (*RemoveDriverRequest) MarshalTo ¶
func (m *RemoveDriverRequest) MarshalTo(dAtA []byte) (int, error)
func (*RemoveDriverRequest) ProtoMessage ¶
func (*RemoveDriverRequest) ProtoMessage()
func (*RemoveDriverRequest) ProtoSize ¶
func (m *RemoveDriverRequest) ProtoSize() (n int)
func (*RemoveDriverRequest) Reset ¶
func (m *RemoveDriverRequest) Reset()
func (*RemoveDriverRequest) String ¶
func (m *RemoveDriverRequest) String() string
func (*RemoveDriverRequest) Unmarshal ¶
func (m *RemoveDriverRequest) Unmarshal(dAtA []byte) error
type Response ¶
func (*Response) Descriptor ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
type Service ¶
type Service interface {
InstallDriver(language string, image string, update bool) error
RemoveDriver(language string) error
DriverStates() ([]*DriverImageState, error)
DriverPoolStates() map[string]*DriverPoolState
DriverInstanceStates() ([]*DriverInstanceState, error)
}
type Status ¶
type Status int
Status is the status of a driver instance.
const ( // Created the container exists but has not been run yet. Created Status = iota // Running the container exists and is running. Running // Pausing the container exists, it is in the process of being paused. Pausing // Paused the container exists, but all its processes are paused. Paused // Stopped the container does not have a created or running process. Stopped )
func (Status) EnumDescriptor ¶
Click to show internal directories.
Click to hide internal directories.