shared

package
v0.9.2 Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2023 License: MIT Imports: 14 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 

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

Types

type RuntimeInfoReport 

type RuntimeInfoReport struct {
	PeerId               string                         `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty" pg:"peer_id"`
	Address              string                         `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty" pg:"address"`
	ServiceName          string                         `protobuf:"bytes,3,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" pg:"service_name"`
	Status               RuntimeInfoReport_HealthStatus `protobuf:"varint,4,opt,name=status,proto3,enum=shared.RuntimeInfoReport_HealthStatus" json:"status,omitempty" pg:"status"`
	CurentTime           time.Time                      `protobuf:"bytes,5,opt,name=curent_time,json=curentTime,proto3,stdtime" json:"curent_time" pg:"curent_time"`
	StartTime            time.Time                      `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" pg:"start_time"`
	GitHash              string                         `protobuf:"bytes,7,opt,name=git_hash,json=gitHash,proto3" json:"git_hash,omitempty" pg:"git_hash"`
	Version              string                         `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty" pg:"version"`
	DbStatusExtra        map[string]string              `` /* 211-byte string literal not displayed */
	RdStatusExtra        string                         `protobuf:"bytes,10,opt,name=rd_status_extra,json=rdStatusExtra,proto3" json:"rd_status_extra,omitempty" pg:"rd_status_extra"`
	QueueStatusExtra     string                         `` /* 136-byte string literal not displayed */
	ChainStatusExtra     string                         `` /* 136-byte string literal not displayed */
	CacheStatusExtra     string                         `` /* 136-byte string literal not displayed */
	Extra                string                         `protobuf:"bytes,14,opt,name=extra,proto3" json:"extra,omitempty" pg:"extra"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-" pg:"-"`
	XXX_unrecognized     []byte                         `json:"-" pg:"-"`
	XXX_sizecache        int32                          `json:"-" pg:"-"`
}

func (*RuntimeInfoReport) Descriptor 

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

func (*RuntimeInfoReport) GetAddress 

func (m *RuntimeInfoReport) GetAddress() string

func (*RuntimeInfoReport) GetCacheStatusExtra 

func (m *RuntimeInfoReport) GetCacheStatusExtra() string

func (*RuntimeInfoReport) GetChainStatusExtra 

func (m *RuntimeInfoReport) GetChainStatusExtra() string

func (*RuntimeInfoReport) GetCurentTime 

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

func (*RuntimeInfoReport) GetDbStatusExtra 

func (m *RuntimeInfoReport) GetDbStatusExtra() map[string]string

func (*RuntimeInfoReport) GetExtra 

func (m *RuntimeInfoReport) GetExtra() string

func (*RuntimeInfoReport) GetGitHash 

func (m *RuntimeInfoReport) GetGitHash() string

func (*RuntimeInfoReport) GetPeerId 

func (m *RuntimeInfoReport) GetPeerId() string

func (*RuntimeInfoReport) GetQueueStatusExtra 

func (m *RuntimeInfoReport) GetQueueStatusExtra() string

func (*RuntimeInfoReport) GetRdStatusExtra 

func (m *RuntimeInfoReport) GetRdStatusExtra() string

func (*RuntimeInfoReport) GetServiceName 

func (m *RuntimeInfoReport) GetServiceName() string

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() string

func (*RuntimeInfoReport) Marshal 

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

func (*RuntimeInfoReport) MarshalTo 

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

func (*RuntimeInfoReport) MarshalToSizedBuffer 

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

func (*RuntimeInfoReport) ProtoMessage 

func (*RuntimeInfoReport) ProtoMessage()

func (*RuntimeInfoReport) Reset 

func (m *RuntimeInfoReport) Reset()

func (*RuntimeInfoReport) Size 

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

func (*RuntimeInfoReport) String 

func (m *RuntimeInfoReport) String() string

func (*RuntimeInfoReport) Unmarshal 

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 

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" pg:"request_address"`
	CurentTime           time.Time `protobuf:"bytes,2,opt,name=curent_time,json=curentTime,proto3,stdtime" json:"curent_time" pg:"curent_time"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-" pg:"-"`
	XXX_unrecognized     []byte    `json:"-" pg:"-"`
	XXX_sizecache        int32     `json:"-" pg:"-"`
}

func (*RuntimeInfoRequest) Descriptor 

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

func (*RuntimeInfoRequest) GetCurentTime 

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

func (*RuntimeInfoRequest) GetRequestAddress 

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

func (*RuntimeInfoRequest) Marshal 

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

func (*RuntimeInfoRequest) MarshalTo 

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

func (*RuntimeInfoRequest) MarshalToSizedBuffer 

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

func (*RuntimeInfoRequest) ProtoMessage 

func (*RuntimeInfoRequest) ProtoMessage()

func (*RuntimeInfoRequest) Reset 

func (m *RuntimeInfoRequest) Reset()

func (*RuntimeInfoRequest) Size 

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

func (*RuntimeInfoRequest) String 

func (m *RuntimeInfoRequest) String() string

func (*RuntimeInfoRequest) Unmarshal 

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 

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 

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 

func NewRuntimeServiceClient(cc *grpc.ClientConn) RuntimeServiceClient

type RuntimeServiceServer 

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

RuntimeServiceServer is the server API for RuntimeService service.

type SignedRuntimeInfoRequest 

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

func (*SignedRuntimeInfoRequest) Descriptor 

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

func (*SignedRuntimeInfoRequest) GetReq 

func (m *SignedRuntimeInfoRequest) GetReq() *RuntimeInfoRequest

func (*SignedRuntimeInfoRequest) GetSignature 

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

func (*SignedRuntimeInfoRequest) Marshal 

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

func (*SignedRuntimeInfoRequest) MarshalTo 

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

func (*SignedRuntimeInfoRequest) MarshalToSizedBuffer 

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

func (*SignedRuntimeInfoRequest) ProtoMessage 

func (*SignedRuntimeInfoRequest) ProtoMessage()

func (*SignedRuntimeInfoRequest) Reset 

func (m *SignedRuntimeInfoRequest) Reset()

func (*SignedRuntimeInfoRequest) Size 

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

func (*SignedRuntimeInfoRequest) String 

func (m *SignedRuntimeInfoRequest) String() string

func (*SignedRuntimeInfoRequest) Unmarshal 

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

func (*SignedRuntimeInfoRequest) XXX_DiscardUnknown 

func (m *SignedRuntimeInfoRequest) XXX_DiscardUnknown()

func (*SignedRuntimeInfoRequest) XXX_Marshal 

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

func (*SignedRuntimeInfoRequest) XXX_Merge 

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

func (*SignedRuntimeInfoRequest) XXX_MessageName 

func (*SignedRuntimeInfoRequest) XXX_MessageName() string

func (*SignedRuntimeInfoRequest) XXX_Size 

func (m *SignedRuntimeInfoRequest) XXX_Size() int

func (*SignedRuntimeInfoRequest) XXX_Unmarshal 

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

type UnimplementedRuntimeServiceServer 

type UnimplementedRuntimeServiceServer struct {
}

UnimplementedRuntimeServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRuntimeServiceServer) CheckRuntime 

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.