mhubapi

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Aug 11, 2018 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var TaskStatus_name = map[int32]string{
	0: "NOT_SENT",
	1: "SENT",
	2: "RECEIVED",
	3: "COMPLETED",
}
View Source 
var TaskStatus_value = map[string]int32{
	"NOT_SENT":  0,
	"SENT":      1,
	"RECEIVED":  2,
	"COMPLETED": 3,
}

Functions

func RegisterMicrologProxyHubServer 

func RegisterMicrologProxyHubServer(s *grpc.Server, srv MicrologProxyHubServer)

Types

type AvailableDSKFStreamInput 

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

func (*AvailableDSKFStreamInput) Descriptor 

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

func (*AvailableDSKFStreamInput) ProtoMessage 

func (*AvailableDSKFStreamInput) ProtoMessage()

func (*AvailableDSKFStreamInput) Reset 

func (m *AvailableDSKFStreamInput) Reset()

func (*AvailableDSKFStreamInput) String 

func (m *AvailableDSKFStreamInput) String() string

func (*AvailableDSKFStreamInput) XXX_DiscardUnknown 

func (m *AvailableDSKFStreamInput) XXX_DiscardUnknown()

func (*AvailableDSKFStreamInput) XXX_Marshal 

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

func (*AvailableDSKFStreamInput) XXX_Merge 

func (dst *AvailableDSKFStreamInput) XXX_Merge(src proto.Message)

func (*AvailableDSKFStreamInput) XXX_Size 

func (m *AvailableDSKFStreamInput) XXX_Size() int

func (*AvailableDSKFStreamInput) XXX_Unmarshal 

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

type AvailableDSKFStreamOutput 

type AvailableDSKFStreamOutput struct {
	TaskId               string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	DskfFile             string   `protobuf:"bytes,2,opt,name=dskf_file,json=dskfFile,proto3" json:"dskf_file,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AvailableDSKFStreamOutput) Descriptor 

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

func (*AvailableDSKFStreamOutput) GetDskfFile 

func (m *AvailableDSKFStreamOutput) GetDskfFile() string

func (*AvailableDSKFStreamOutput) GetTaskId 

func (m *AvailableDSKFStreamOutput) GetTaskId() string

func (*AvailableDSKFStreamOutput) ProtoMessage 

func (*AvailableDSKFStreamOutput) ProtoMessage()

func (*AvailableDSKFStreamOutput) Reset 

func (m *AvailableDSKFStreamOutput) Reset()

func (*AvailableDSKFStreamOutput) String 

func (m *AvailableDSKFStreamOutput) String() string

func (*AvailableDSKFStreamOutput) XXX_DiscardUnknown 

func (m *AvailableDSKFStreamOutput) XXX_DiscardUnknown()

func (*AvailableDSKFStreamOutput) XXX_Marshal 

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

func (*AvailableDSKFStreamOutput) XXX_Merge 

func (dst *AvailableDSKFStreamOutput) XXX_Merge(src proto.Message)

func (*AvailableDSKFStreamOutput) XXX_Size 

func (m *AvailableDSKFStreamOutput) XXX_Size() int

func (*AvailableDSKFStreamOutput) XXX_Unmarshal 

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

type DeepPingOutput 

type DeepPingOutput struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeepPingOutput) Descriptor 

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

func (*DeepPingOutput) GetValue 

func (m *DeepPingOutput) GetValue() string

func (*DeepPingOutput) ProtoMessage 

func (*DeepPingOutput) ProtoMessage()

func (*DeepPingOutput) Reset 

func (m *DeepPingOutput) Reset()

func (*DeepPingOutput) String 

func (m *DeepPingOutput) String() string

func (*DeepPingOutput) XXX_DiscardUnknown 

func (m *DeepPingOutput) XXX_DiscardUnknown()

func (*DeepPingOutput) XXX_Marshal 

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

func (*DeepPingOutput) XXX_Merge 

func (dst *DeepPingOutput) XXX_Merge(src proto.Message)

func (*DeepPingOutput) XXX_Size 

func (m *DeepPingOutput) XXX_Size() int

func (*DeepPingOutput) XXX_Unmarshal 

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

type MicrologProxyHubClient 

type MicrologProxyHubClient interface {
	DeepPing(ctx context.Context, in *Void, opts ...grpc.CallOption) (*DeepPingOutput, error)
	SetTaskStatus(ctx context.Context, in *SetTaskStatusInput, opts ...grpc.CallOption) (*Void, error)
	AvailableDSKFStream(ctx context.Context, in *AvailableDSKFStreamInput, opts ...grpc.CallOption) (MicrologProxyHub_AvailableDSKFStreamClient, error)
}

MicrologProxyHubClient is the client API for MicrologProxyHub service.

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

func NewMicrologProxyHubClient 

func NewMicrologProxyHubClient(cc *grpc.ClientConn) MicrologProxyHubClient

type MicrologProxyHubServer 

type MicrologProxyHubServer interface {
	DeepPing(context.Context, *Void) (*DeepPingOutput, error)
	SetTaskStatus(context.Context, *SetTaskStatusInput) (*Void, error)
	AvailableDSKFStream(*AvailableDSKFStreamInput, MicrologProxyHub_AvailableDSKFStreamServer) error
}

MicrologProxyHubServer is the server API for MicrologProxyHub service.

type MicrologProxyHub_AvailableDSKFStreamClient 

type MicrologProxyHub_AvailableDSKFStreamClient interface {
	Recv() (*AvailableDSKFStreamOutput, error)
	grpc.ClientStream
}

type MicrologProxyHub_AvailableDSKFStreamServer 

type MicrologProxyHub_AvailableDSKFStreamServer interface {
	Send(*AvailableDSKFStreamOutput) error
	grpc.ServerStream
}

type SetTaskStatusInput 

type SetTaskStatusInput struct {
	TaskId               string     `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	UserId               string     `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Status               TaskStatus `protobuf:"varint,3,opt,name=status,proto3,enum=mhubapi.TaskStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SetTaskStatusInput) Descriptor 

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

func (*SetTaskStatusInput) GetStatus 

func (m *SetTaskStatusInput) GetStatus() TaskStatus

func (*SetTaskStatusInput) GetTaskId 

func (m *SetTaskStatusInput) GetTaskId() string

func (*SetTaskStatusInput) GetUserId 

func (m *SetTaskStatusInput) GetUserId() string

func (*SetTaskStatusInput) ProtoMessage 

func (*SetTaskStatusInput) ProtoMessage()

func (*SetTaskStatusInput) Reset 

func (m *SetTaskStatusInput) Reset()

func (*SetTaskStatusInput) String 

func (m *SetTaskStatusInput) String() string

func (*SetTaskStatusInput) XXX_DiscardUnknown 

func (m *SetTaskStatusInput) XXX_DiscardUnknown()

func (*SetTaskStatusInput) XXX_Marshal 

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

func (*SetTaskStatusInput) XXX_Merge 

func (dst *SetTaskStatusInput) XXX_Merge(src proto.Message)

func (*SetTaskStatusInput) XXX_Size 

func (m *SetTaskStatusInput) XXX_Size() int

func (*SetTaskStatusInput) XXX_Unmarshal 

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

type TaskStatus 

type TaskStatus int32
const (
	TaskStatus_NOT_SENT  TaskStatus = 0
	TaskStatus_SENT      TaskStatus = 1
	TaskStatus_RECEIVED  TaskStatus = 2
	TaskStatus_COMPLETED TaskStatus = 3
)

func (TaskStatus) EnumDescriptor 

func (TaskStatus) EnumDescriptor() ([]byte, []int)

func (TaskStatus) String 

func (x TaskStatus) String() string

type Void 

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

func (*Void) Descriptor 

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

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) Reset 

func (m *Void) Reset()

func (*Void) String 

func (m *Void) String() string

func (*Void) XXX_DiscardUnknown 

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal 

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

func (*Void) XXX_Merge 

func (dst *Void) XXX_Merge(src proto.Message)

func (*Void) XXX_Size 

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal 

func (m *Void) 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.