pb

package
v0.0.0-...-f4cebfc Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview 

Package pb is a generated protocol buffer package.

It is generated from these files:
	pb/counselor.proto

It has these top-level messages:
	CheckActionReqResp
	DestinationConfig

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCounselor = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCounselor   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterCounselorServiceHandler 

func RegisterCounselorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterCounselorServiceHandler registers the http handlers for service CounselorService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterCounselorServiceHandlerFromEndpoint 

func RegisterCounselorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterCounselorServiceHandlerFromEndpoint is same as RegisterCounselorServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterCounselorServiceServer 

func RegisterCounselorServiceServer(s *grpc.Server, srv CounselorServiceServer)

Types

type CheckActionReqResp 

type CheckActionReqResp struct {
	Name               string                        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Command            []string                      `protobuf:"bytes,2,rep,name=command" json:"command,omitempty"`
	Args               []string                      `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	Env                []string                      `protobuf:"bytes,4,rep,name=env" json:"env,omitempty"`
	Conf               map[string]string             `` /* 142-byte string literal not displayed */
	WorkDir            string                        `protobuf:"bytes,6,opt,name=work_dir,json=workDir,proto3" json:"work_dir,omitempty"`
	Periodic           int32                         `protobuf:"varint,7,opt,name=periodic,proto3" json:"periodic,omitempty"`
	Duration           int32                         `protobuf:"varint,8,opt,name=duration,proto3" json:"duration,omitempty"`
	DestConfigurations map[string]*DestinationConfig `` /* 189-byte string literal not displayed */
	StateCode          int32                         `protobuf:"varint,10,opt,name=state_code,json=stateCode,proto3" json:"state_code,omitempty"`
	StateMessage       string                        `protobuf:"bytes,11,opt,name=state_message,json=stateMessage,proto3" json:"state_message,omitempty"`
	Timestamp          string                        `protobuf:"bytes,12,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	DestinationPath    string                        `protobuf:"bytes,13,opt,name=destination_path,json=destinationPath,proto3" json:"destination_path,omitempty"`
}

func (*CheckActionReqResp) Descriptor 

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

func (*CheckActionReqResp) GetArgs 

func (m *CheckActionReqResp) GetArgs() []string

func (*CheckActionReqResp) GetCommand 

func (m *CheckActionReqResp) GetCommand() []string

func (*CheckActionReqResp) GetConf 

func (m *CheckActionReqResp) GetConf() map[string]string

func (*CheckActionReqResp) GetDestConfigurations 

func (m *CheckActionReqResp) GetDestConfigurations() map[string]*DestinationConfig

func (*CheckActionReqResp) GetDestinationPath 

func (m *CheckActionReqResp) GetDestinationPath() string

func (*CheckActionReqResp) GetDuration 

func (m *CheckActionReqResp) GetDuration() int32

func (*CheckActionReqResp) GetEnv 

func (m *CheckActionReqResp) GetEnv() []string

func (*CheckActionReqResp) GetName 

func (m *CheckActionReqResp) GetName() string

func (*CheckActionReqResp) GetPeriodic 

func (m *CheckActionReqResp) GetPeriodic() int32

func (*CheckActionReqResp) GetStateCode 

func (m *CheckActionReqResp) GetStateCode() int32

func (*CheckActionReqResp) GetStateMessage 

func (m *CheckActionReqResp) GetStateMessage() string

func (*CheckActionReqResp) GetTimestamp 

func (m *CheckActionReqResp) GetTimestamp() string

func (*CheckActionReqResp) GetWorkDir 

func (m *CheckActionReqResp) GetWorkDir() string

func (*CheckActionReqResp) Marshal 

func (m *CheckActionReqResp) Marshal() (dAtA []byte, err error)

func (*CheckActionReqResp) MarshalTo 

func (m *CheckActionReqResp) MarshalTo(dAtA []byte) (int, error)

func (*CheckActionReqResp) ProtoMessage 

func (*CheckActionReqResp) ProtoMessage()

func (*CheckActionReqResp) Reset 

func (m *CheckActionReqResp) Reset()

func (*CheckActionReqResp) Size 

func (m *CheckActionReqResp) Size() (n int)

func (*CheckActionReqResp) String 

func (m *CheckActionReqResp) String() string

func (*CheckActionReqResp) Unmarshal 

func (m *CheckActionReqResp) Unmarshal(dAtA []byte) error

type CounselorServiceClient 

type CounselorServiceClient interface {
	CreateCheck(ctx context.Context, in *CheckActionReqResp, opts ...grpc.CallOption) (*CheckActionReqResp, error)
	ReapCheck(ctx context.Context, in *CheckActionReqResp, opts ...grpc.CallOption) (*CheckActionReqResp, error)
	UpdateCheck(ctx context.Context, in *CheckActionReqResp, opts ...grpc.CallOption) (*CheckActionReqResp, error)
	DeleteCheck(ctx context.Context, in *CheckActionReqResp, opts ...grpc.CallOption) (*CheckActionReqResp, error)
}

func NewCounselorServiceClient 

func NewCounselorServiceClient(cc *grpc.ClientConn) CounselorServiceClient

type CounselorServiceServer 

type CounselorServiceServer interface {
	CreateCheck(context.Context, *CheckActionReqResp) (*CheckActionReqResp, error)
	ReapCheck(context.Context, *CheckActionReqResp) (*CheckActionReqResp, error)
	UpdateCheck(context.Context, *CheckActionReqResp) (*CheckActionReqResp, error)
	DeleteCheck(context.Context, *CheckActionReqResp) (*CheckActionReqResp, error)
}

type DestinationConfig 

type DestinationConfig struct {
	Name            string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Command         []string          `protobuf:"bytes,2,rep,name=command" json:"command,omitempty"`
	Args            []string          `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	Env             []string          `protobuf:"bytes,4,rep,name=env" json:"env,omitempty"`
	Conf            map[string]string `` /* 142-byte string literal not displayed */
	WorkDir         string            `protobuf:"bytes,6,opt,name=work_dir,json=workDir,proto3" json:"work_dir,omitempty"`
	Periodic        int32             `protobuf:"varint,7,opt,name=periodic,proto3" json:"periodic,omitempty"`
	Duration        int32             `protobuf:"varint,8,opt,name=duration,proto3" json:"duration,omitempty"`
	Tpl             map[string]string `` /* 140-byte string literal not displayed */
	StateCode       int32             `protobuf:"varint,10,opt,name=state_code,json=stateCode,proto3" json:"state_code,omitempty"`
	StateMessage    string            `protobuf:"bytes,11,opt,name=state_message,json=stateMessage,proto3" json:"state_message,omitempty"`
	Timestamp       string            `protobuf:"bytes,12,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	DestinationPath string            `protobuf:"bytes,13,opt,name=destination_path,json=destinationPath,proto3" json:"destination_path,omitempty"`
}

func (*DestinationConfig) Descriptor 

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

func (*DestinationConfig) GetArgs 

func (m *DestinationConfig) GetArgs() []string

func (*DestinationConfig) GetCommand 

func (m *DestinationConfig) GetCommand() []string

func (*DestinationConfig) GetConf 

func (m *DestinationConfig) GetConf() map[string]string

func (*DestinationConfig) GetDestinationPath 

func (m *DestinationConfig) GetDestinationPath() string

func (*DestinationConfig) GetDuration 

func (m *DestinationConfig) GetDuration() int32

func (*DestinationConfig) GetEnv 

func (m *DestinationConfig) GetEnv() []string

func (*DestinationConfig) GetName 

func (m *DestinationConfig) GetName() string

func (*DestinationConfig) GetPeriodic 

func (m *DestinationConfig) GetPeriodic() int32

func (*DestinationConfig) GetStateCode 

func (m *DestinationConfig) GetStateCode() int32

func (*DestinationConfig) GetStateMessage 

func (m *DestinationConfig) GetStateMessage() string

func (*DestinationConfig) GetTimestamp 

func (m *DestinationConfig) GetTimestamp() string

func (*DestinationConfig) GetTpl 

func (m *DestinationConfig) GetTpl() map[string]string

func (*DestinationConfig) GetWorkDir 

func (m *DestinationConfig) GetWorkDir() string

func (*DestinationConfig) Marshal 

func (m *DestinationConfig) Marshal() (dAtA []byte, err error)

func (*DestinationConfig) MarshalTo 

func (m *DestinationConfig) MarshalTo(dAtA []byte) (int, error)

func (*DestinationConfig) ProtoMessage 

func (*DestinationConfig) ProtoMessage()

func (*DestinationConfig) Reset 

func (m *DestinationConfig) Reset()

func (*DestinationConfig) Size 

func (m *DestinationConfig) Size() (n int)

func (*DestinationConfig) String 

func (m *DestinationConfig) String() string

func (*DestinationConfig) Unmarshal 

func (m *DestinationConfig) Unmarshal(dAtA []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.