api

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_api_proto_server_proto protoreflect.FileDescriptor

Functions

func RegisterGazerSystemServer 

func RegisterGazerSystemServer(s *grpc.Server, srv GazerSystemServer)

Types

type AddTasksReq 

type AddTasksReq struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTasksReq) Descriptor deprecated 

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

Deprecated: Use AddTasksReq.ProtoReflect.Descriptor instead.

func (*AddTasksReq) GetTasks 

func (x *AddTasksReq) GetTasks() []*Task

func (*AddTasksReq) ProtoMessage 

func (*AddTasksReq) ProtoMessage()

func (*AddTasksReq) ProtoReflect 

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

func (*AddTasksReq) Reset 

func (x *AddTasksReq) Reset()

func (*AddTasksReq) String 

func (x *AddTasksReq) String() string

type ConsumeRawsReq 

type ConsumeRawsReq struct {
	IdList []uint64 `protobuf:"varint,1,rep,packed,name=idList,proto3" json:"idList,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumeRawsReq) Descriptor deprecated 

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

Deprecated: Use ConsumeRawsReq.ProtoReflect.Descriptor instead.

func (*ConsumeRawsReq) GetIdList 

func (x *ConsumeRawsReq) GetIdList() []uint64

func (*ConsumeRawsReq) ProtoMessage 

func (*ConsumeRawsReq) ProtoMessage()

func (*ConsumeRawsReq) ProtoReflect 

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

func (*ConsumeRawsReq) Reset 

func (x *ConsumeRawsReq) Reset()

func (*ConsumeRawsReq) String 

func (x *ConsumeRawsReq) String() string

type GazerSystemClient 

type GazerSystemClient interface {
	AddTasks(ctx context.Context, in *AddTasksReq, opts ...grpc.CallOption) (*OperationResp, error)
	ListRaws(ctx context.Context, in *ListRawsReq, opts ...grpc.CallOption) (*RawsResp, error)
	ConsumeRaws(ctx context.Context, in *ConsumeRawsReq, opts ...grpc.CallOption) (*OperationResp, error)
}

GazerSystemClient is the client API for GazerSystem service.

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

func NewGazerSystemClient 

func NewGazerSystemClient(cc grpc.ClientConnInterface) GazerSystemClient

type GazerSystemServer 

type GazerSystemServer interface {
	AddTasks(context.Context, *AddTasksReq) (*OperationResp, error)
	ListRaws(context.Context, *ListRawsReq) (*RawsResp, error)
	ConsumeRaws(context.Context, *ConsumeRawsReq) (*OperationResp, error)
}

GazerSystemServer is the server API for GazerSystem service.

type ListRawsReq 

type ListRawsReq struct {
	Tag   string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Url   string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRawsReq) Descriptor deprecated 

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

Deprecated: Use ListRawsReq.ProtoReflect.Descriptor instead.

func (*ListRawsReq) GetLimit 

func (x *ListRawsReq) GetLimit() uint32

func (*ListRawsReq) GetTag 

func (x *ListRawsReq) GetTag() string

func (*ListRawsReq) GetUrl 

func (x *ListRawsReq) GetUrl() string

func (*ListRawsReq) ProtoMessage 

func (*ListRawsReq) ProtoMessage()

func (*ListRawsReq) ProtoReflect 

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

func (*ListRawsReq) Reset 

func (x *ListRawsReq) Reset()

func (*ListRawsReq) String 

func (x *ListRawsReq) String() string

type OperationResp 

type OperationResp struct {
	Code int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationResp) Descriptor deprecated 

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

Deprecated: Use OperationResp.ProtoReflect.Descriptor instead.

func (*OperationResp) GetCode 

func (x *OperationResp) GetCode() int32

func (*OperationResp) GetMsg 

func (x *OperationResp) GetMsg() string

func (*OperationResp) ProtoMessage 

func (*OperationResp) ProtoMessage()

func (*OperationResp) ProtoReflect 

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

func (*OperationResp) Reset 

func (x *OperationResp) Reset()

func (*OperationResp) String 

func (x *OperationResp) String() string

type Raw 

type Raw struct {
	Id        uint64                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Url       string                 `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Tag       string                 `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Data      []byte                 `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Raw) Descriptor deprecated 

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

Deprecated: Use Raw.ProtoReflect.Descriptor instead.

func (*Raw) GetData 

func (x *Raw) GetData() []byte

func (*Raw) GetId 

func (x *Raw) GetId() uint64

func (*Raw) GetTag 

func (x *Raw) GetTag() string

func (*Raw) GetTimestamp 

func (x *Raw) GetTimestamp() *timestamppb.Timestamp

func (*Raw) GetUrl 

func (x *Raw) GetUrl() string

func (*Raw) ProtoMessage 

func (*Raw) ProtoMessage()

func (*Raw) ProtoReflect 

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

func (*Raw) Reset 

func (x *Raw) Reset()

func (*Raw) String 

func (x *Raw) String() string

type RawsResp 

type RawsResp struct {
	Raws []*Raw `protobuf:"bytes,1,rep,name=raws,proto3" json:"raws,omitempty"`
	// contains filtered or unexported fields
}

func (*RawsResp) Descriptor deprecated 

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

Deprecated: Use RawsResp.ProtoReflect.Descriptor instead.

func (*RawsResp) GetRaws 

func (x *RawsResp) GetRaws() []*Raw

func (*RawsResp) ProtoMessage 

func (*RawsResp) ProtoMessage()

func (*RawsResp) ProtoReflect 

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

func (*RawsResp) Reset 

func (x *RawsResp) Reset()

func (*RawsResp) String 

func (x *RawsResp) String() string

type Task 

type Task struct {
	Url        string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Tag        string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	IntervalMS uint64 `protobuf:"varint,3,opt,name=intervalMS,proto3" json:"intervalMS,omitempty"`
	// contains filtered or unexported fields
}

Add a Task

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetIntervalMS 

func (x *Task) GetIntervalMS() uint64

func (*Task) GetTag 

func (x *Task) GetTag() string

func (*Task) GetUrl 

func (x *Task) GetUrl() string

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type UnimplementedGazerSystemServer 

type UnimplementedGazerSystemServer struct {
}

UnimplementedGazerSystemServer can be embedded to have forward compatible implementations.

func (*UnimplementedGazerSystemServer) AddTasks 

func (*UnimplementedGazerSystemServer) AddTasks(context.Context, *AddTasksReq) (*OperationResp, error)

func (*UnimplementedGazerSystemServer) ConsumeRaws 

func (*UnimplementedGazerSystemServer) ConsumeRaws(context.Context, *ConsumeRawsReq) (*OperationResp, error)

func (*UnimplementedGazerSystemServer) ListRaws 

func (*UnimplementedGazerSystemServer) ListRaws(context.Context, *ListRawsReq) (*RawsResp, 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.