types

Documentation

Index

• Variables
• func RegisterSinkServer(s *grpc.Server, srv SinkServer)
• type Blockdevice
  • func (*Blockdevice) Descriptor() ([]byte, []int)
  • func (x *Blockdevice) GetMajor() int32
  • func (x *Blockdevice) GetMinor() int32
  • func (x *Blockdevice) GetName() string
  • func (x *Blockdevice) GetOperation() string
  • func (*Blockdevice) ProtoMessage()
  • func (x *Blockdevice) ProtoReflect() protoreflect.Message
  • func (x *Blockdevice) Reset()
  • func (x *Blockdevice) String() string
• type Error
  • func (*Error) Descriptor() ([]byte, []int)
  • func (x *Error) GetCode() int32
  • func (x *Error) GetDomain() string
  • func (x *Error) GetMessage() string
  • func (x *Error) GetSource() string
  • func (*Error) ProtoMessage()
  • func (x *Error) ProtoReflect() protoreflect.Message
  • func (x *Error) Reset()
  • func (x *Error) String() string
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (x *Event) GetData() *any.Any
  • func (x *Event) GetId() string
  • func (*Event) ProtoMessage()
  • func (x *Event) ProtoReflect() protoreflect.Message
  • func (x *Event) Reset()
  • func (x *Event) String() string
• type IO
  • func (*IO) Descriptor() ([]byte, []int)
  • func (x *IO) GetCommand() string
  • func (x *IO) GetDisk() string
  • func (x *IO) GetOperation() string
  • func (x *IO) GetPid() uint32
  • func (*IO) ProtoMessage()
  • func (x *IO) ProtoReflect() protoreflect.Message
  • func (x *IO) Reset()
  • func (x *IO) String() string
• type SinkClient
  • func NewSinkClient(cc grpc.ClientConnInterface) SinkClient
• type SinkServer
• type Sink_EventsClient
• type Sink_EventsServer
• type UnimplementedSinkServer
  • func (*UnimplementedSinkServer) Events(Sink_EventsServer) error

Variables

var File_api_proto protoreflect.FileDescriptor

Functions

func RegisterSinkServer

func RegisterSinkServer(s *grpc.Server, srv SinkServer)

Types

type Blockdevice

type Blockdevice struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Major     int32  `protobuf:"varint,2,opt,name=major,proto3" json:"major,omitempty"`
	Minor     int32  `protobuf:"varint,3,opt,name=minor,proto3" json:"minor,omitempty"`
	Operation string `protobuf:"bytes,4,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*Blockdevice) Descriptor

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

Deprecated: Use Blockdevice.ProtoReflect.Descriptor instead.

func (*Blockdevice) GetMajor

func (x *Blockdevice) GetMajor() int32

func (*Blockdevice) GetMinor

func (x *Blockdevice) GetMinor() int32

func (*Blockdevice) GetName

func (x *Blockdevice) GetName() string

func (*Blockdevice) GetOperation

func (x *Blockdevice) GetOperation() string

func (*Blockdevice) ProtoMessage

func (*Blockdevice) ProtoMessage()

func (*Blockdevice) ProtoReflect

func (x *Blockdevice) ProtoReflect() protoreflect.Message

func (*Blockdevice) Reset

func (x *Blockdevice) Reset()

func (*Blockdevice) String

func (x *Blockdevice) String() string

type Error

type Error struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Domain  string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	Source  string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode

func (x *Error) GetCode() int32

func (*Error) GetDomain

func (x *Error) GetDomain() string

func (*Error) GetMessage

func (x *Error) GetMessage() string

func (*Error) GetSource

func (x *Error) GetSource() string

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) ProtoReflect

func (x *Error) ProtoReflect() protoreflect.Message

func (*Error) Reset

func (x *Error) Reset()

func (*Error) String

func (x *Error) String() string

type Event

type Event struct {
	Data *any.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Id   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetData

func (x *Event) GetData() *any.Any

func (*Event) GetId

func (x *Event) GetId() string

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type IO

type IO struct {
	Command   string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Pid       uint32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	Disk      string `protobuf:"bytes,3,opt,name=disk,proto3" json:"disk,omitempty"`
	Operation string `protobuf:"bytes,4,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*IO) Descriptor

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

Deprecated: Use IO.ProtoReflect.Descriptor instead.

func (*IO) GetCommand

func (x *IO) GetCommand() string

func (*IO) GetDisk

func (x *IO) GetDisk() string

func (*IO) GetOperation

func (x *IO) GetOperation() string

func (*IO) GetPid

func (x *IO) GetPid() uint32

func (*IO) ProtoMessage

func (*IO) ProtoMessage()

func (*IO) ProtoReflect

func (x *IO) ProtoReflect() protoreflect.Message

func (*IO) Reset

func (x *IO) Reset()

func (*IO) String

func (x *IO) String() string

type SinkClient

type SinkClient interface {
	Events(ctx context.Context, opts ...grpc.CallOption) (Sink_EventsClient, error)
}

SinkClient is the client API for Sink service.

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

func NewSinkClient

func NewSinkClient(cc grpc.ClientConnInterface) SinkClient

type SinkServer

type SinkServer interface {
	Events(Sink_EventsServer) error
}

SinkServer is the server API for Sink service.

type Sink_EventsClient

type Sink_EventsClient interface {
	Send(*Event) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type Sink_EventsServer

type Sink_EventsServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type UnimplementedSinkServer

type UnimplementedSinkServer struct {
}

UnimplementedSinkServer can be embedded to have forward compatible implementations.

func (*UnimplementedSinkServer) Events

func (*UnimplementedSinkServer) Events(Sink_EventsServer) error