proto

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jun 22, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterLVServiceServer 

func RegisterLVServiceServer(s *grpc.Server, srv LVServiceServer)

func RegisterVGServiceServer 

func RegisterVGServiceServer(s *grpc.Server, srv VGServiceServer)

Types

type CreateLVRequest 

type CreateLVRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SizeGb               uint64   `protobuf:"varint,2,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"`
	Tags                 []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	DeviceClass          string   `protobuf:"bytes,4,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents the input for CreateLV.

func (*CreateLVRequest) Descriptor 

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

func (*CreateLVRequest) GetDeviceClass added in v0.5.0 

func (m *CreateLVRequest) GetDeviceClass() string

func (*CreateLVRequest) GetName 

func (m *CreateLVRequest) GetName() string

func (*CreateLVRequest) GetSizeGb 

func (m *CreateLVRequest) GetSizeGb() uint64

func (*CreateLVRequest) GetTags added in v0.3.0 

func (m *CreateLVRequest) GetTags() []string

func (*CreateLVRequest) ProtoMessage 

func (*CreateLVRequest) ProtoMessage()

func (*CreateLVRequest) Reset 

func (m *CreateLVRequest) Reset()

func (*CreateLVRequest) String 

func (m *CreateLVRequest) String() string

func (*CreateLVRequest) XXX_DiscardUnknown 

func (m *CreateLVRequest) XXX_DiscardUnknown()

func (*CreateLVRequest) XXX_Marshal 

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

func (*CreateLVRequest) XXX_Merge 

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

func (*CreateLVRequest) XXX_Size 

func (m *CreateLVRequest) XXX_Size() int

func (*CreateLVRequest) XXX_Unmarshal 

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

type CreateLVResponse 

type CreateLVResponse struct {
	Volume               *LogicalVolume `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Represents the response of CreateLV.

func (*CreateLVResponse) Descriptor 

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

func (*CreateLVResponse) GetVolume 

func (m *CreateLVResponse) GetVolume() *LogicalVolume

func (*CreateLVResponse) ProtoMessage 

func (*CreateLVResponse) ProtoMessage()

func (*CreateLVResponse) Reset 

func (m *CreateLVResponse) Reset()

func (*CreateLVResponse) String 

func (m *CreateLVResponse) String() string

func (*CreateLVResponse) XXX_DiscardUnknown 

func (m *CreateLVResponse) XXX_DiscardUnknown()

func (*CreateLVResponse) XXX_Marshal 

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

func (*CreateLVResponse) XXX_Merge 

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

func (*CreateLVResponse) XXX_Size 

func (m *CreateLVResponse) XXX_Size() int

func (*CreateLVResponse) XXX_Unmarshal 

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

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type GetFreeBytesRequest added in v0.5.0 

type GetFreeBytesRequest struct {
	DeviceClass          string   `protobuf:"bytes,1,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFreeBytesRequest) Descriptor added in v0.5.0 

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

func (*GetFreeBytesRequest) GetDeviceClass added in v0.5.0 

func (m *GetFreeBytesRequest) GetDeviceClass() string

func (*GetFreeBytesRequest) ProtoMessage added in v0.5.0 

func (*GetFreeBytesRequest) ProtoMessage()

func (*GetFreeBytesRequest) Reset added in v0.5.0 

func (m *GetFreeBytesRequest) Reset()

func (*GetFreeBytesRequest) String added in v0.5.0 

func (m *GetFreeBytesRequest) String() string

func (*GetFreeBytesRequest) XXX_DiscardUnknown added in v0.5.0 

func (m *GetFreeBytesRequest) XXX_DiscardUnknown()

func (*GetFreeBytesRequest) XXX_Marshal added in v0.5.0 

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

func (*GetFreeBytesRequest) XXX_Merge added in v0.5.0 

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

func (*GetFreeBytesRequest) XXX_Size added in v0.5.0 

func (m *GetFreeBytesRequest) XXX_Size() int

func (*GetFreeBytesRequest) XXX_Unmarshal added in v0.5.0 

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

type GetFreeBytesResponse 

type GetFreeBytesResponse struct {
	FreeBytes            uint64   `protobuf:"varint,1,opt,name=free_bytes,json=freeBytes,proto3" json:"free_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents the response of GetFreeBytes.

func (*GetFreeBytesResponse) Descriptor 

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

func (*GetFreeBytesResponse) GetFreeBytes 

func (m *GetFreeBytesResponse) GetFreeBytes() uint64

func (*GetFreeBytesResponse) ProtoMessage 

func (*GetFreeBytesResponse) ProtoMessage()

func (*GetFreeBytesResponse) Reset 

func (m *GetFreeBytesResponse) Reset()

func (*GetFreeBytesResponse) String 

func (m *GetFreeBytesResponse) String() string

func (*GetFreeBytesResponse) XXX_DiscardUnknown 

func (m *GetFreeBytesResponse) XXX_DiscardUnknown()

func (*GetFreeBytesResponse) XXX_Marshal 

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

func (*GetFreeBytesResponse) XXX_Merge 

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

func (*GetFreeBytesResponse) XXX_Size 

func (m *GetFreeBytesResponse) XXX_Size() int

func (*GetFreeBytesResponse) XXX_Unmarshal 

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

type GetLVListRequest added in v0.5.0 

type GetLVListRequest struct {
	DeviceClass          string   `protobuf:"bytes,1,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetLVListRequest) Descriptor added in v0.5.0 

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

func (*GetLVListRequest) GetDeviceClass added in v0.5.0 

func (m *GetLVListRequest) GetDeviceClass() string

func (*GetLVListRequest) ProtoMessage added in v0.5.0 

func (*GetLVListRequest) ProtoMessage()

func (*GetLVListRequest) Reset added in v0.5.0 

func (m *GetLVListRequest) Reset()

func (*GetLVListRequest) String added in v0.5.0 

func (m *GetLVListRequest) String() string

func (*GetLVListRequest) XXX_DiscardUnknown added in v0.5.0 

func (m *GetLVListRequest) XXX_DiscardUnknown()

func (*GetLVListRequest) XXX_Marshal added in v0.5.0 

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

func (*GetLVListRequest) XXX_Merge added in v0.5.0 

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

func (*GetLVListRequest) XXX_Size added in v0.5.0 

func (m *GetLVListRequest) XXX_Size() int

func (*GetLVListRequest) XXX_Unmarshal added in v0.5.0 

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

type GetLVListResponse 

type GetLVListResponse struct {
	Volumes              []*LogicalVolume `protobuf:"bytes,1,rep,name=volumes,proto3" json:"volumes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Represents the response of GetLVList.

func (*GetLVListResponse) Descriptor 

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

func (*GetLVListResponse) GetVolumes 

func (m *GetLVListResponse) GetVolumes() []*LogicalVolume

func (*GetLVListResponse) ProtoMessage 

func (*GetLVListResponse) ProtoMessage()

func (*GetLVListResponse) Reset 

func (m *GetLVListResponse) Reset()

func (*GetLVListResponse) String 

func (m *GetLVListResponse) String() string

func (*GetLVListResponse) XXX_DiscardUnknown 

func (m *GetLVListResponse) XXX_DiscardUnknown()

func (*GetLVListResponse) XXX_Marshal 

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

func (*GetLVListResponse) XXX_Merge 

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

func (*GetLVListResponse) XXX_Size 

func (m *GetLVListResponse) XXX_Size() int

func (*GetLVListResponse) XXX_Unmarshal 

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

type LVServiceClient 

type LVServiceClient interface {
	// Create a logical volume.
	CreateLV(ctx context.Context, in *CreateLVRequest, opts ...grpc.CallOption) (*CreateLVResponse, error)
	// Remove a logical volume.
	RemoveLV(ctx context.Context, in *RemoveLVRequest, opts ...grpc.CallOption) (*Empty, error)
	// Resize a logical volume.
	ResizeLV(ctx context.Context, in *ResizeLVRequest, opts ...grpc.CallOption) (*Empty, error)
}

LVServiceClient is the client API for LVService service.

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

func NewLVServiceClient 

func NewLVServiceClient(cc grpc.ClientConnInterface) LVServiceClient

type LVServiceServer 

type LVServiceServer interface {
	// Create a logical volume.
	CreateLV(context.Context, *CreateLVRequest) (*CreateLVResponse, error)
	// Remove a logical volume.
	RemoveLV(context.Context, *RemoveLVRequest) (*Empty, error)
	// Resize a logical volume.
	ResizeLV(context.Context, *ResizeLVRequest) (*Empty, error)
}

LVServiceServer is the server API for LVService service.

type LogicalVolume 

type LogicalVolume struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SizeGb               uint64   `protobuf:"varint,2,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"`
	DevMajor             uint32   `protobuf:"varint,3,opt,name=dev_major,json=devMajor,proto3" json:"dev_major,omitempty"`
	DevMinor             uint32   `protobuf:"varint,4,opt,name=dev_minor,json=devMinor,proto3" json:"dev_minor,omitempty"`
	Tags                 []string `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents a logical volume.

func (*LogicalVolume) Descriptor 

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

func (*LogicalVolume) GetDevMajor 

func (m *LogicalVolume) GetDevMajor() uint32

func (*LogicalVolume) GetDevMinor 

func (m *LogicalVolume) GetDevMinor() uint32

func (*LogicalVolume) GetName 

func (m *LogicalVolume) GetName() string

func (*LogicalVolume) GetSizeGb 

func (m *LogicalVolume) GetSizeGb() uint64

func (*LogicalVolume) GetTags added in v0.3.0 

func (m *LogicalVolume) GetTags() []string

func (*LogicalVolume) ProtoMessage 

func (*LogicalVolume) ProtoMessage()

func (*LogicalVolume) Reset 

func (m *LogicalVolume) Reset()

func (*LogicalVolume) String 

func (m *LogicalVolume) String() string

func (*LogicalVolume) XXX_DiscardUnknown 

func (m *LogicalVolume) XXX_DiscardUnknown()

func (*LogicalVolume) XXX_Marshal 

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

func (*LogicalVolume) XXX_Merge 

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

func (*LogicalVolume) XXX_Size 

func (m *LogicalVolume) XXX_Size() int

func (*LogicalVolume) XXX_Unmarshal 

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

type RemoveLVRequest 

type RemoveLVRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	DeviceClass          string   `protobuf:"bytes,2,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents the input for RemoveLV.

func (*RemoveLVRequest) Descriptor 

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

func (*RemoveLVRequest) GetDeviceClass added in v0.5.0 

func (m *RemoveLVRequest) GetDeviceClass() string

func (*RemoveLVRequest) GetName 

func (m *RemoveLVRequest) GetName() string

func (*RemoveLVRequest) ProtoMessage 

func (*RemoveLVRequest) ProtoMessage()

func (*RemoveLVRequest) Reset 

func (m *RemoveLVRequest) Reset()

func (*RemoveLVRequest) String 

func (m *RemoveLVRequest) String() string

func (*RemoveLVRequest) XXX_DiscardUnknown 

func (m *RemoveLVRequest) XXX_DiscardUnknown()

func (*RemoveLVRequest) XXX_Marshal 

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

func (*RemoveLVRequest) XXX_Merge 

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

func (*RemoveLVRequest) XXX_Size 

func (m *RemoveLVRequest) XXX_Size() int

func (*RemoveLVRequest) XXX_Unmarshal 

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

type ResizeLVRequest 

type ResizeLVRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SizeGb               uint64   `protobuf:"varint,2,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"`
	DeviceClass          string   `protobuf:"bytes,3,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents the input for ResizeLV.

The volume must already exist. The volume size will be set to exactly "size_gb".

func (*ResizeLVRequest) Descriptor 

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

func (*ResizeLVRequest) GetDeviceClass added in v0.5.0 

func (m *ResizeLVRequest) GetDeviceClass() string

func (*ResizeLVRequest) GetName 

func (m *ResizeLVRequest) GetName() string

func (*ResizeLVRequest) GetSizeGb 

func (m *ResizeLVRequest) GetSizeGb() uint64

func (*ResizeLVRequest) ProtoMessage 

func (*ResizeLVRequest) ProtoMessage()

func (*ResizeLVRequest) Reset 

func (m *ResizeLVRequest) Reset()

func (*ResizeLVRequest) String 

func (m *ResizeLVRequest) String() string

func (*ResizeLVRequest) XXX_DiscardUnknown 

func (m *ResizeLVRequest) XXX_DiscardUnknown()

func (*ResizeLVRequest) XXX_Marshal 

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

func (*ResizeLVRequest) XXX_Merge 

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

func (*ResizeLVRequest) XXX_Size 

func (m *ResizeLVRequest) XXX_Size() int

func (*ResizeLVRequest) XXX_Unmarshal 

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

type UnimplementedLVServiceServer added in v0.2.1 

type UnimplementedLVServiceServer struct {
}

UnimplementedLVServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedLVServiceServer) CreateLV added in v0.2.1 

func (*UnimplementedLVServiceServer) CreateLV(ctx context.Context, req *CreateLVRequest) (*CreateLVResponse, error)

func (*UnimplementedLVServiceServer) RemoveLV added in v0.2.1 

func (*UnimplementedLVServiceServer) RemoveLV(ctx context.Context, req *RemoveLVRequest) (*Empty, error)

func (*UnimplementedLVServiceServer) ResizeLV added in v0.2.1 

func (*UnimplementedLVServiceServer) ResizeLV(ctx context.Context, req *ResizeLVRequest) (*Empty, error)

type UnimplementedVGServiceServer added in v0.2.1 

type UnimplementedVGServiceServer struct {
}

UnimplementedVGServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedVGServiceServer) GetFreeBytes added in v0.2.1 

func (*UnimplementedVGServiceServer) GetFreeBytes(ctx context.Context, req *GetFreeBytesRequest) (*GetFreeBytesResponse, error)

func (*UnimplementedVGServiceServer) GetLVList added in v0.2.1 

func (*UnimplementedVGServiceServer) GetLVList(ctx context.Context, req *GetLVListRequest) (*GetLVListResponse, error)

func (*UnimplementedVGServiceServer) Watch added in v0.2.1 

func (*UnimplementedVGServiceServer) Watch(req *Empty, srv VGService_WatchServer) error

type VGServiceClient 

type VGServiceClient interface {
	// Get the list of logical volumes in the volume group.
	GetLVList(ctx context.Context, in *GetLVListRequest, opts ...grpc.CallOption) (*GetLVListResponse, error)
	// Get the free space of the volume group in bytes.
	GetFreeBytes(ctx context.Context, in *GetFreeBytesRequest, opts ...grpc.CallOption) (*GetFreeBytesResponse, error)
	// Stream the volume group metrics.
	Watch(ctx context.Context, in *Empty, opts ...grpc.CallOption) (VGService_WatchClient, error)
}

VGServiceClient is the client API for VGService service.

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

func NewVGServiceClient 

func NewVGServiceClient(cc grpc.ClientConnInterface) VGServiceClient

type VGServiceServer 

type VGServiceServer interface {
	// Get the list of logical volumes in the volume group.
	GetLVList(context.Context, *GetLVListRequest) (*GetLVListResponse, error)
	// Get the free space of the volume group in bytes.
	GetFreeBytes(context.Context, *GetFreeBytesRequest) (*GetFreeBytesResponse, error)
	// Stream the volume group metrics.
	Watch(*Empty, VGService_WatchServer) error
}

VGServiceServer is the server API for VGService service.

type VGService_WatchClient 

type VGService_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type VGService_WatchServer 

type VGService_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type WatchItem added in v0.5.0 

type WatchItem struct {
	FreeBytes            uint64   `protobuf:"varint,1,opt,name=free_bytes,json=freeBytes,proto3" json:"free_bytes,omitempty"`
	DeviceClass          string   `protobuf:"bytes,2,opt,name=device_class,json=deviceClass,proto3" json:"device_class,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchItem) Descriptor added in v0.5.0 

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

func (*WatchItem) GetDeviceClass added in v0.5.0 

func (m *WatchItem) GetDeviceClass() string

func (*WatchItem) GetFreeBytes added in v0.5.0 

func (m *WatchItem) GetFreeBytes() uint64

func (*WatchItem) ProtoMessage added in v0.5.0 

func (*WatchItem) ProtoMessage()

func (*WatchItem) Reset added in v0.5.0 

func (m *WatchItem) Reset()

func (*WatchItem) String added in v0.5.0 

func (m *WatchItem) String() string

func (*WatchItem) XXX_DiscardUnknown added in v0.5.0 

func (m *WatchItem) XXX_DiscardUnknown()

func (*WatchItem) XXX_Marshal added in v0.5.0 

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

func (*WatchItem) XXX_Merge added in v0.5.0 

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

func (*WatchItem) XXX_Size added in v0.5.0 

func (m *WatchItem) XXX_Size() int

func (*WatchItem) XXX_Unmarshal added in v0.5.0 

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

type WatchResponse 

type WatchResponse struct {
	FreeBytes            uint64       `protobuf:"varint,1,opt,name=free_bytes,json=freeBytes,proto3" json:"free_bytes,omitempty"`
	Items                []*WatchItem `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Represents the stream output from Watch.

func (*WatchResponse) Descriptor 

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

func (*WatchResponse) GetFreeBytes 

func (m *WatchResponse) GetFreeBytes() uint64

func (*WatchResponse) GetItems added in v0.5.0 

func (m *WatchResponse) GetItems() []*WatchItem

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) Reset 

func (m *WatchResponse) Reset()

func (*WatchResponse) String 

func (m *WatchResponse) String() string

func (*WatchResponse) XXX_DiscardUnknown 

func (m *WatchResponse) XXX_DiscardUnknown()

func (*WatchResponse) XXX_Marshal 

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

func (*WatchResponse) XXX_Merge 

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

func (*WatchResponse) XXX_Size 

func (m *WatchResponse) XXX_Size() int

func (*WatchResponse) XXX_Unmarshal 

func (m *WatchResponse) XXX_Unmarshal(b []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.