shared

package
v0.0.15 Latest Latest
Warning

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

 Go to latest Published: Nov 19, 2019 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthShared        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowShared          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupShared = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var RuntimeInfoReport_HealthStatus_name = map[int32]string{
	0: "SICK",
	1: "RUNNING",
	2: "BOOTSTRAP",
	3: "PARTIAL_STOP",
}
View Source 
var RuntimeInfoReport_HealthStatus_value = map[string]int32{
	"SICK":         0,
	"RUNNING":      1,
	"BOOTSTRAP":    2,
	"PARTIAL_STOP": 3,
}

Functions

func RegisterRuntimeServiceServer added in v0.0.14 

func RegisterRuntimeServiceServer(s *grpc.Server, srv RuntimeServiceServer)

Types

type RuntimeInfoReport 

type RuntimeInfoReport struct {
	PeerId               []byte                         `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	Address              []byte                         `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	ServiceName          []byte                         `protobuf:"bytes,3,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	Status               RuntimeInfoReport_HealthStatus `protobuf:"varint,4,opt,name=status,proto3,enum=shared.RuntimeInfoReport_HealthStatus" json:"status,omitempty"`
	CurentTime           *time.Time                     `protobuf:"bytes,5,opt,name=curent_time,json=curentTime,proto3,stdtime" json:"curent_time,omitempty"`
	StartTime            *time.Time                     `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	GitHash              []byte                         `protobuf:"bytes,7,opt,name=git_hash,json=gitHash,proto3" json:"git_hash,omitempty"`
	Version              []byte                         `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"`
	DbStatusExtra        []byte                         `protobuf:"bytes,9,opt,name=db_status_extra,json=dbStatusExtra,proto3" json:"db_status_extra,omitempty"`
	RdStatusExtra        []byte                         `protobuf:"bytes,10,opt,name=rd_status_extra,json=rdStatusExtra,proto3" json:"rd_status_extra,omitempty"`
	QueueStatusExtra     []byte                         `protobuf:"bytes,11,opt,name=queue_status_extra,json=queueStatusExtra,proto3" json:"queue_status_extra,omitempty"`
	ChainStatusExtra     []byte                         `protobuf:"bytes,12,opt,name=chain_status_extra,json=chainStatusExtra,proto3" json:"chain_status_extra,omitempty"`
	CacheStatusExtra     []byte                         `protobuf:"bytes,13,opt,name=cache_status_extra,json=cacheStatusExtra,proto3" json:"cache_status_extra,omitempty"`
	Extra                []byte                         `protobuf:"bytes,14,opt,name=extra,proto3" json:"extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*RuntimeInfoReport) Descriptor 

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

func (*RuntimeInfoReport) GetAddress 

func (m *RuntimeInfoReport) GetAddress() []byte

func (*RuntimeInfoReport) GetCacheStatusExtra 

func (m *RuntimeInfoReport) GetCacheStatusExtra() []byte

func (*RuntimeInfoReport) GetChainStatusExtra 

func (m *RuntimeInfoReport) GetChainStatusExtra() []byte

func (*RuntimeInfoReport) GetCurentTime 

func (m *RuntimeInfoReport) GetCurentTime() *time.Time

func (*RuntimeInfoReport) GetDbStatusExtra 

func (m *RuntimeInfoReport) GetDbStatusExtra() []byte

func (*RuntimeInfoReport) GetExtra 

func (m *RuntimeInfoReport) GetExtra() []byte

func (*RuntimeInfoReport) GetGitHash 

func (m *RuntimeInfoReport) GetGitHash() []byte

func (*RuntimeInfoReport) GetPeerId 

func (m *RuntimeInfoReport) GetPeerId() []byte

func (*RuntimeInfoReport) GetQueueStatusExtra 

func (m *RuntimeInfoReport) GetQueueStatusExtra() []byte

func (*RuntimeInfoReport) GetRdStatusExtra added in v0.0.14 

func (m *RuntimeInfoReport) GetRdStatusExtra() []byte

func (*RuntimeInfoReport) GetServiceName 

func (m *RuntimeInfoReport) GetServiceName() []byte

func (*RuntimeInfoReport) GetStartTime 

func (m *RuntimeInfoReport) GetStartTime() *time.Time

func (*RuntimeInfoReport) GetStatus 

func (m *RuntimeInfoReport) GetStatus() RuntimeInfoReport_HealthStatus

func (*RuntimeInfoReport) GetVersion 

func (m *RuntimeInfoReport) GetVersion() []byte

func (*RuntimeInfoReport) Marshal added in v0.0.13 

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

func (*RuntimeInfoReport) MarshalTo added in v0.0.13 

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

func (*RuntimeInfoReport) MarshalToSizedBuffer added in v0.0.13 

func (m *RuntimeInfoReport) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RuntimeInfoReport) ProtoMessage 

func (*RuntimeInfoReport) ProtoMessage()

func (*RuntimeInfoReport) Reset 

func (m *RuntimeInfoReport) Reset()

func (*RuntimeInfoReport) Size added in v0.0.13 

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

func (*RuntimeInfoReport) String 

func (m *RuntimeInfoReport) String() string

func (*RuntimeInfoReport) Unmarshal added in v0.0.13 

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

func (*RuntimeInfoReport) XXX_DiscardUnknown 

func (m *RuntimeInfoReport) XXX_DiscardUnknown()

func (*RuntimeInfoReport) XXX_Marshal 

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

func (*RuntimeInfoReport) XXX_Merge 

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

func (*RuntimeInfoReport) XXX_MessageName added in v0.0.13 

func (*RuntimeInfoReport) XXX_MessageName() string

func (*RuntimeInfoReport) XXX_Size 

func (m *RuntimeInfoReport) XXX_Size() int

func (*RuntimeInfoReport) XXX_Unmarshal 

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

type RuntimeInfoReport_HealthStatus 

type RuntimeInfoReport_HealthStatus int32
const (
	RuntimeInfoReport_SICK         RuntimeInfoReport_HealthStatus = 0
	RuntimeInfoReport_RUNNING      RuntimeInfoReport_HealthStatus = 1
	RuntimeInfoReport_BOOTSTRAP    RuntimeInfoReport_HealthStatus = 2
	RuntimeInfoReport_PARTIAL_STOP RuntimeInfoReport_HealthStatus = 3
)

func (RuntimeInfoReport_HealthStatus) EnumDescriptor 

func (RuntimeInfoReport_HealthStatus) EnumDescriptor() ([]byte, []int)

func (RuntimeInfoReport_HealthStatus) String 

func (x RuntimeInfoReport_HealthStatus) String() string

type RuntimeInfoRequest 

type RuntimeInfoRequest struct {
	RequestAddress       []byte           `protobuf:"bytes,1,opt,name=request_address,json=requestAddress,proto3" json:"request_address,omitempty"`
	CurentTime           *types.Timestamp `protobuf:"bytes,2,opt,name=curent_time,json=curentTime,proto3" json:"curent_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*RuntimeInfoRequest) Descriptor 

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

func (*RuntimeInfoRequest) GetCurentTime 

func (m *RuntimeInfoRequest) GetCurentTime() *types.Timestamp

func (*RuntimeInfoRequest) GetRequestAddress 

func (m *RuntimeInfoRequest) GetRequestAddress() []byte

func (*RuntimeInfoRequest) Marshal added in v0.0.13 

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

func (*RuntimeInfoRequest) MarshalTo added in v0.0.13 

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

func (*RuntimeInfoRequest) MarshalToSizedBuffer added in v0.0.13 

func (m *RuntimeInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RuntimeInfoRequest) ProtoMessage 

func (*RuntimeInfoRequest) ProtoMessage()

func (*RuntimeInfoRequest) Reset 

func (m *RuntimeInfoRequest) Reset()

func (*RuntimeInfoRequest) Size added in v0.0.13 

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

func (*RuntimeInfoRequest) String 

func (m *RuntimeInfoRequest) String() string

func (*RuntimeInfoRequest) Unmarshal added in v0.0.13 

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

func (*RuntimeInfoRequest) XXX_DiscardUnknown 

func (m *RuntimeInfoRequest) XXX_DiscardUnknown()

func (*RuntimeInfoRequest) XXX_Marshal 

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

func (*RuntimeInfoRequest) XXX_Merge 

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

func (*RuntimeInfoRequest) XXX_MessageName added in v0.0.13 

func (*RuntimeInfoRequest) XXX_MessageName() string

func (*RuntimeInfoRequest) XXX_Size 

func (m *RuntimeInfoRequest) XXX_Size() int

func (*RuntimeInfoRequest) XXX_Unmarshal 

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

type RuntimeServiceClient added in v0.0.14 

type RuntimeServiceClient interface {
	CheckRuntime(ctx context.Context, in *SignedRuntimeInfoRequest, opts ...grpc.CallOption) (*RuntimeInfoReport, error)
}

RuntimeServiceClient is the client API for RuntimeService service.

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

func NewRuntimeServiceClient added in v0.0.14 

func NewRuntimeServiceClient(cc *grpc.ClientConn) RuntimeServiceClient

type RuntimeServiceServer added in v0.0.14 

type RuntimeServiceServer interface {
	CheckRuntime(context.Context, *SignedRuntimeInfoRequest) (*RuntimeInfoReport, error)
}

RuntimeServiceServer is the server API for RuntimeService service.

type SignedRuntimeInfoRequest added in v0.0.14 

type SignedRuntimeInfoRequest struct {
	Req                  *RuntimeInfoRequest `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"`
	Signature            []byte              `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SignedRuntimeInfoRequest) Descriptor added in v0.0.14 

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

func (*SignedRuntimeInfoRequest) GetReq added in v0.0.14 

func (m *SignedRuntimeInfoRequest) GetReq() *RuntimeInfoRequest

func (*SignedRuntimeInfoRequest) GetSignature added in v0.0.14 

func (m *SignedRuntimeInfoRequest) GetSignature() []byte

func (*SignedRuntimeInfoRequest) Marshal added in v0.0.14 

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

func (*SignedRuntimeInfoRequest) MarshalTo added in v0.0.14 

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

func (*SignedRuntimeInfoRequest) MarshalToSizedBuffer added in v0.0.14 

func (m *SignedRuntimeInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SignedRuntimeInfoRequest) ProtoMessage added in v0.0.14 

func (*SignedRuntimeInfoRequest) ProtoMessage()

func (*SignedRuntimeInfoRequest) Reset added in v0.0.14 

func (m *SignedRuntimeInfoRequest) Reset()

func (*SignedRuntimeInfoRequest) Size added in v0.0.14 

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

func (*SignedRuntimeInfoRequest) String added in v0.0.14 

func (m *SignedRuntimeInfoRequest) String() string

func (*SignedRuntimeInfoRequest) Unmarshal added in v0.0.14 

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

func (*SignedRuntimeInfoRequest) XXX_DiscardUnknown added in v0.0.14 

func (m *SignedRuntimeInfoRequest) XXX_DiscardUnknown()

func (*SignedRuntimeInfoRequest) XXX_Marshal added in v0.0.14 

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

func (*SignedRuntimeInfoRequest) XXX_Merge added in v0.0.14 

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

func (*SignedRuntimeInfoRequest) XXX_MessageName added in v0.0.14 

func (*SignedRuntimeInfoRequest) XXX_MessageName() string

func (*SignedRuntimeInfoRequest) XXX_Size added in v0.0.14 

func (m *SignedRuntimeInfoRequest) XXX_Size() int

func (*SignedRuntimeInfoRequest) XXX_Unmarshal added in v0.0.14 

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

type UnimplementedRuntimeServiceServer added in v0.0.14 

type UnimplementedRuntimeServiceServer struct {
}

UnimplementedRuntimeServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRuntimeServiceServer) CheckRuntime added in v0.0.14 

func (*UnimplementedRuntimeServiceServer) CheckRuntime(ctx context.Context, req *SignedRuntimeInfoRequest) (*RuntimeInfoReport, 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.