metrics

Documentation

Index

• Variables
• func RegisterIngestionServer(s *grpc.Server, srv IngestionServer)
• type IngestionClient
  • func NewIngestionClient(cc *grpc.ClientConn) IngestionClient
• type IngestionServer
• type SubmitRequest
  • func (*SubmitRequest) Descriptor() ([]byte, []int)
  • func (*SubmitRequest) ProtoMessage()
  • func (m *SubmitRequest) Reset()
  • func (m *SubmitRequest) String() string
  • func (m *SubmitRequest) Validate() error
  • func (m *SubmitRequest) XXX_DiscardUnknown()
  • func (m *SubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SubmitRequest) XXX_Merge(src proto.Message)
  • func (m *SubmitRequest) XXX_Size() int
  • func (m *SubmitRequest) XXX_Unmarshal(b []byte) error
• type SubmitRequestValidationError
  • func (e SubmitRequestValidationError) Cause() error
  • func (e SubmitRequestValidationError) Error() string
  • func (e SubmitRequestValidationError) ErrorName() string
  • func (e SubmitRequestValidationError) Field() string
  • func (e SubmitRequestValidationError) Key() bool
  • func (e SubmitRequestValidationError) Reason() string
• type SubmitResponse
  • func (*SubmitResponse) Descriptor() ([]byte, []int)
  • func (m *SubmitResponse) GetResult() SubmitResponse_Result
  • func (*SubmitResponse) ProtoMessage()
  • func (m *SubmitResponse) Reset()
  • func (m *SubmitResponse) String() string
  • func (m *SubmitResponse) Validate() error
  • func (m *SubmitResponse) XXX_DiscardUnknown()
  • func (m *SubmitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SubmitResponse) XXX_Merge(src proto.Message)
  • func (m *SubmitResponse) XXX_Size() int
  • func (m *SubmitResponse) XXX_Unmarshal(b []byte) error
• type SubmitResponseValidationError
  • func (e SubmitResponseValidationError) Cause() error
  • func (e SubmitResponseValidationError) Error() string
  • func (e SubmitResponseValidationError) ErrorName() string
  • func (e SubmitResponseValidationError) Field() string
  • func (e SubmitResponseValidationError) Key() bool
  • func (e SubmitResponseValidationError) Reason() string
• type SubmitResponse_Result
  • func (SubmitResponse_Result) EnumDescriptor() ([]byte, []int)
  • func (x SubmitResponse_Result) String() string
• type UnimplementedIngestionServer
  • func (*UnimplementedIngestionServer) Submit(ctx context.Context, req *SubmitRequest) (*SubmitResponse, error)

Variables

var SubmitResponse_Result_name = map[int32]string{
	0: "OK",
}

var SubmitResponse_Result_value = map[string]int32{
	"OK": 0,
}

Functions

func RegisterIngestionServer

func RegisterIngestionServer(s *grpc.Server, srv IngestionServer)

Types

type IngestionClient

type IngestionClient interface {
	Submit(ctx context.Context, in *SubmitRequest, opts ...grpc.CallOption) (*SubmitResponse, error)
}

IngestionClient is the client API for Ingestion service.

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

func NewIngestionClient

func NewIngestionClient(cc *grpc.ClientConn) IngestionClient

type IngestionServer

type IngestionServer interface {
	Submit(context.Context, *SubmitRequest) (*SubmitResponse, error)
}

IngestionServer is the server API for Ingestion service.

type SubmitRequest

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

func (*SubmitRequest) Descriptor

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

func (*SubmitRequest) ProtoMessage

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) Reset

func (m *SubmitRequest) Reset()

func (*SubmitRequest) String

func (m *SubmitRequest) String() string

func (*SubmitRequest) Validate

func (m *SubmitRequest) Validate() error

Validate checks the field values on SubmitRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SubmitRequest) XXX_DiscardUnknown

func (m *SubmitRequest) XXX_DiscardUnknown()

func (*SubmitRequest) XXX_Marshal

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

func (*SubmitRequest) XXX_Merge

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

func (*SubmitRequest) XXX_Size

func (m *SubmitRequest) XXX_Size() int

func (*SubmitRequest) XXX_Unmarshal

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

type SubmitRequestValidationError

type SubmitRequestValidationError struct {
	// contains filtered or unexported fields
}

SubmitRequestValidationError is the validation error returned by SubmitRequest.Validate if the designated constraints aren't met.

func (SubmitRequestValidationError) Cause

func (e SubmitRequestValidationError) Cause() error

Cause function returns cause value.

func (SubmitRequestValidationError) Error

func (e SubmitRequestValidationError) Error() string

Error satisfies the builtin error interface

func (SubmitRequestValidationError) ErrorName

func (e SubmitRequestValidationError) ErrorName() string

ErrorName returns error name.

func (SubmitRequestValidationError) Field

func (e SubmitRequestValidationError) Field() string

Field function returns field value.

func (SubmitRequestValidationError) Key

func (e SubmitRequestValidationError) Key() bool

Key function returns key value.

func (SubmitRequestValidationError) Reason

func (e SubmitRequestValidationError) Reason() string

Reason function returns reason value.

type SubmitResponse

type SubmitResponse struct {
	Result               SubmitResponse_Result `protobuf:"varint,1,opt,name=result,proto3,enum=kin.agora.metrics.v3.SubmitResponse_Result" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*SubmitResponse) Descriptor

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

func (*SubmitResponse) GetResult

func (m *SubmitResponse) GetResult() SubmitResponse_Result

func (*SubmitResponse) ProtoMessage

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) Reset

func (m *SubmitResponse) Reset()

func (*SubmitResponse) String

func (m *SubmitResponse) String() string

func (*SubmitResponse) Validate

func (m *SubmitResponse) Validate() error

Validate checks the field values on SubmitResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SubmitResponse) XXX_DiscardUnknown

func (m *SubmitResponse) XXX_DiscardUnknown()

func (*SubmitResponse) XXX_Marshal

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

func (*SubmitResponse) XXX_Merge

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

func (*SubmitResponse) XXX_Size

func (m *SubmitResponse) XXX_Size() int

func (*SubmitResponse) XXX_Unmarshal

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

type SubmitResponseValidationError

type SubmitResponseValidationError struct {
	// contains filtered or unexported fields
}

SubmitResponseValidationError is the validation error returned by SubmitResponse.Validate if the designated constraints aren't met.

func (SubmitResponseValidationError) Cause

func (e SubmitResponseValidationError) Cause() error

Cause function returns cause value.

func (SubmitResponseValidationError) Error

func (e SubmitResponseValidationError) Error() string

Error satisfies the builtin error interface

func (SubmitResponseValidationError) ErrorName

func (e SubmitResponseValidationError) ErrorName() string

ErrorName returns error name.

func (SubmitResponseValidationError) Field

func (e SubmitResponseValidationError) Field() string

Field function returns field value.

func (SubmitResponseValidationError) Key

func (e SubmitResponseValidationError) Key() bool

Key function returns key value.

func (SubmitResponseValidationError) Reason

func (e SubmitResponseValidationError) Reason() string

Reason function returns reason value.

type SubmitResponse_Result

type SubmitResponse_Result int32

const (
	SubmitResponse_OK SubmitResponse_Result = 0
)

func (SubmitResponse_Result) EnumDescriptor

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

func (SubmitResponse_Result) String

func (x SubmitResponse_Result) String() string

type UnimplementedIngestionServer

type UnimplementedIngestionServer struct {
}

UnimplementedIngestionServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngestionServer) Submit

func (*UnimplementedIngestionServer) Submit(ctx context.Context, req *SubmitRequest) (*SubmitResponse, error)