v3

package
v0.0.0-...-5b17d3f Latest Latest
Warning

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

Go to latest
Published: Jun 28, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterManagementServiceServer

func RegisterManagementServiceServer(s *grpc.Server, srv ManagementServiceServer)

Types

type InstancePingPkg

type InstancePingPkg struct {
	Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	ServiceInstance      string   `protobuf:"bytes,2,opt,name=serviceInstance,proto3" json:"serviceInstance,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InstancePingPkg) Descriptor

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

func (*InstancePingPkg) GetService

func (m *InstancePingPkg) GetService() string

func (*InstancePingPkg) GetServiceInstance

func (m *InstancePingPkg) GetServiceInstance() string

func (*InstancePingPkg) ProtoMessage

func (*InstancePingPkg) ProtoMessage()

func (*InstancePingPkg) Reset

func (m *InstancePingPkg) Reset()

func (*InstancePingPkg) String

func (m *InstancePingPkg) String() string

func (*InstancePingPkg) XXX_DiscardUnknown

func (m *InstancePingPkg) XXX_DiscardUnknown()

func (*InstancePingPkg) XXX_Marshal

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

func (*InstancePingPkg) XXX_Merge

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

func (*InstancePingPkg) XXX_Size

func (m *InstancePingPkg) XXX_Size() int

func (*InstancePingPkg) XXX_Unmarshal

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

type InstanceProperties

type InstanceProperties struct {
	Service              string                   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	ServiceInstance      string                   `protobuf:"bytes,2,opt,name=serviceInstance,proto3" json:"serviceInstance,omitempty"`
	Properties           []*v3.KeyStringValuePair `protobuf:"bytes,3,rep,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*InstanceProperties) Descriptor

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

func (*InstanceProperties) GetProperties

func (m *InstanceProperties) GetProperties() []*v3.KeyStringValuePair

func (*InstanceProperties) GetService

func (m *InstanceProperties) GetService() string

func (*InstanceProperties) GetServiceInstance

func (m *InstanceProperties) GetServiceInstance() string

func (*InstanceProperties) ProtoMessage

func (*InstanceProperties) ProtoMessage()

func (*InstanceProperties) Reset

func (m *InstanceProperties) Reset()

func (*InstanceProperties) String

func (m *InstanceProperties) String() string

func (*InstanceProperties) XXX_DiscardUnknown

func (m *InstanceProperties) XXX_DiscardUnknown()

func (*InstanceProperties) XXX_Marshal

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

func (*InstanceProperties) XXX_Merge

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

func (*InstanceProperties) XXX_Size

func (m *InstanceProperties) XXX_Size() int

func (*InstanceProperties) XXX_Unmarshal

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

type ManagementServiceClient

type ManagementServiceClient interface {
	ReportInstanceProperties(ctx context.Context, in *InstanceProperties, opts ...grpc.CallOption) (*v3.Commands, error)
	KeepAlive(ctx context.Context, in *InstancePingPkg, opts ...grpc.CallOption) (*v3.Commands, error)
}

ManagementServiceClient is the client API for ManagementService service.

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

func NewManagementServiceClient

func NewManagementServiceClient(cc *grpc.ClientConn) ManagementServiceClient

type ManagementServiceServer

type ManagementServiceServer interface {
	ReportInstanceProperties(context.Context, *InstanceProperties) (*v3.Commands, error)
	KeepAlive(context.Context, *InstancePingPkg) (*v3.Commands, error)
}

ManagementServiceServer is the server API for ManagementService service.

type UnimplementedManagementServiceServer

type UnimplementedManagementServiceServer struct {
}

UnimplementedManagementServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedManagementServiceServer) KeepAlive

func (*UnimplementedManagementServiceServer) ReportInstanceProperties

func (*UnimplementedManagementServiceServer) ReportInstanceProperties(ctx context.Context, req *InstanceProperties) (*v3.Commands, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL