v1

Documentation

Index

• Variables
• func RegisterPollConfigServer(s *grpc.Server, srv PollConfigServer)
• type PollConfigClient
  • func NewPollConfigClient(cc *grpc.ClientConn) PollConfigClient
• type PollConfigServer
• type PollRequest
  • func (*PollRequest) Descriptor() ([]byte, []int)
  • func (m *PollRequest) GetCurrentHash() string
  • func (m *PollRequest) GetResource() *v1.Resource
  • func (m *PollRequest) GetTs() int64
  • func (m *PollRequest) Marshal() (dAtA []byte, err error)
  • func (m *PollRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *PollRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PollRequest) ProtoMessage()
  • func (m *PollRequest) Reset()
  • func (m *PollRequest) Size() (n int)
  • func (m *PollRequest) String() string
  • func (m *PollRequest) Unmarshal(dAtA []byte) error
  • func (m *PollRequest) XXX_DiscardUnknown()
  • func (m *PollRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PollRequest) XXX_Merge(src proto.Message)
  • func (m *PollRequest) XXX_Size() int
  • func (m *PollRequest) XXX_Unmarshal(b []byte) error
• type PollResponse
  • func (*PollResponse) Descriptor() ([]byte, []int)
  • func (m *PollResponse) GetCurrentHash() string
  • func (m *PollResponse) GetResponse() []*v11.TracePointConfig
  • func (m *PollResponse) GetResponseType() ResponseType
  • func (m *PollResponse) GetTs() int64
  • func (m *PollResponse) Marshal() (dAtA []byte, err error)
  • func (m *PollResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *PollResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PollResponse) ProtoMessage()
  • func (m *PollResponse) Reset()
  • func (m *PollResponse) Size() (n int)
  • func (m *PollResponse) String() string
  • func (m *PollResponse) Unmarshal(dAtA []byte) error
  • func (m *PollResponse) XXX_DiscardUnknown()
  • func (m *PollResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PollResponse) XXX_Merge(src proto.Message)
  • func (m *PollResponse) XXX_Size() int
  • func (m *PollResponse) XXX_Unmarshal(b []byte) error
• type ResponseType
  • func (ResponseType) EnumDescriptor() ([]byte, []int)
  • func (x ResponseType) String() string
• type UnimplementedPollConfigServer
  • func (*UnimplementedPollConfigServer) Poll(ctx context.Context, req *PollRequest) (*PollResponse, error)

Variables

var (
	ErrInvalidLengthPoll        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPoll          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPoll = fmt.Errorf("proto: unexpected end of group")
)

var ResponseType_name = map[int32]string{
	0: "NO_CHANGE",
	1: "UPDATE",
}

var ResponseType_value = map[string]int32{
	"NO_CHANGE": 0,
	"UPDATE":    1,
}

Functions

func RegisterPollConfigServer

func RegisterPollConfigServer(s *grpc.Server, srv PollConfigServer)

Types

type PollConfigClient

type PollConfigClient interface {
	//Call this function as often as is required to ensure config is up to date.
	Poll(ctx context.Context, in *PollRequest, opts ...grpc.CallOption) (*PollResponse, error)
}

PollConfigClient is the client API for PollConfig service.

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

func NewPollConfigClient

func NewPollConfigClient(cc *grpc.ClientConn) PollConfigClient

type PollConfigServer

type PollConfigServer interface {
	//Call this function as often as is required to ensure config is up to date.
	Poll(context.Context, *PollRequest) (*PollResponse, error)
}

PollConfigServer is the server API for PollConfig service.

type PollRequest

type PollRequest struct {
	Ts          int64        `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"`
	CurrentHash string       `protobuf:"bytes,2,opt,name=current_hash,json=currentHash,proto3" json:"current_hash,omitempty"`
	Resource    *v1.Resource `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
}

func (*PollRequest) Descriptor

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

func (*PollRequest) GetCurrentHash

func (m *PollRequest) GetCurrentHash() string

func (*PollRequest) GetResource

func (m *PollRequest) GetResource() *v1.Resource

func (*PollRequest) GetTs

func (m *PollRequest) GetTs() int64

func (*PollRequest) Marshal

func (m *PollRequest) Marshal() (dAtA []byte, err error)

func (*PollRequest) MarshalTo

func (m *PollRequest) MarshalTo(dAtA []byte) (int, error)

func (*PollRequest) MarshalToSizedBuffer

func (m *PollRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PollRequest) ProtoMessage

func (*PollRequest) ProtoMessage()

func (*PollRequest) Reset

func (m *PollRequest) Reset()

func (*PollRequest) Size

func (m *PollRequest) Size() (n int)

func (*PollRequest) String

func (m *PollRequest) String() string

func (*PollRequest) Unmarshal

func (m *PollRequest) Unmarshal(dAtA []byte) error

func (*PollRequest) XXX_DiscardUnknown

func (m *PollRequest) XXX_DiscardUnknown()

func (*PollRequest) XXX_Marshal

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

func (*PollRequest) XXX_Merge

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

func (*PollRequest) XXX_Size

func (m *PollRequest) XXX_Size() int

func (*PollRequest) XXX_Unmarshal

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

type PollResponse

type PollResponse struct {
	Ts           int64                   `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"`
	CurrentHash  string                  `protobuf:"bytes,2,opt,name=current_hash,json=currentHash,proto3" json:"current_hash,omitempty"`
	Response     []*v11.TracePointConfig `protobuf:"bytes,3,rep,name=response,proto3" json:"response,omitempty"`
	ResponseType ResponseType            `` /* 140-byte string literal not displayed */
}

func (*PollResponse) Descriptor

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

func (*PollResponse) GetCurrentHash

func (m *PollResponse) GetCurrentHash() string

func (*PollResponse) GetResponse

func (m *PollResponse) GetResponse() []*v11.TracePointConfig

func (*PollResponse) GetResponseType

func (m *PollResponse) GetResponseType() ResponseType

func (*PollResponse) GetTs

func (m *PollResponse) GetTs() int64

func (*PollResponse) Marshal

func (m *PollResponse) Marshal() (dAtA []byte, err error)

func (*PollResponse) MarshalTo

func (m *PollResponse) MarshalTo(dAtA []byte) (int, error)

func (*PollResponse) MarshalToSizedBuffer

func (m *PollResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PollResponse) ProtoMessage

func (*PollResponse) ProtoMessage()

func (*PollResponse) Reset

func (m *PollResponse) Reset()

func (*PollResponse) Size

func (m *PollResponse) Size() (n int)

func (*PollResponse) String

func (m *PollResponse) String() string

func (*PollResponse) Unmarshal

func (m *PollResponse) Unmarshal(dAtA []byte) error

func (*PollResponse) XXX_DiscardUnknown

func (m *PollResponse) XXX_DiscardUnknown()

func (*PollResponse) XXX_Marshal

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

func (*PollResponse) XXX_Merge

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

func (*PollResponse) XXX_Size

func (m *PollResponse) XXX_Size() int

func (*PollResponse) XXX_Unmarshal

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

type ResponseType

type ResponseType int32

const (
	ResponseType_NO_CHANGE ResponseType = 0
	ResponseType_UPDATE    ResponseType = 1
)

func (ResponseType) EnumDescriptor

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

func (ResponseType) String

func (x ResponseType) String() string

type UnimplementedPollConfigServer

type UnimplementedPollConfigServer struct {
}

UnimplementedPollConfigServer can be embedded to have forward compatible implementations.

func (*UnimplementedPollConfigServer) Poll

func (*UnimplementedPollConfigServer) Poll(ctx context.Context, req *PollRequest) (*PollResponse, error)