grpc

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 2018 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAPIServer 

func RegisterAPIServer(s *grpc.Server, srv APIServer)

Types

type APIClient 

type APIClient interface {
	CreateRule(ctx context.Context, in *CreateRuleRequest, opts ...grpc.CallOption) (*CreateRuleResponse, error)
	RemoveRule(ctx context.Context, in *RemoveRuleRequest, opts ...grpc.CallOption) (*RemoveRuleResponse, error)
	ListRules(ctx context.Context, in *ListRulesRequest, opts ...grpc.CallOption) (*ListRulesResponse, error)
	LiveTrace(ctx context.Context, in *LiveTraceRequest, opts ...grpc.CallOption) (API_LiveTraceClient, error)
}

APIClient is the client API for API service.

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

func NewAPIClient 

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer 

type APIServer interface {
	CreateRule(context.Context, *CreateRuleRequest) (*CreateRuleResponse, error)
	RemoveRule(context.Context, *RemoveRuleRequest) (*RemoveRuleResponse, error)
	ListRules(context.Context, *ListRulesRequest) (*ListRulesResponse, error)
	LiveTrace(*LiveTraceRequest, API_LiveTraceServer) error
}

APIServer is the server API for API service.

type API_LiveTraceClient 

type API_LiveTraceClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type API_LiveTraceServer 

type API_LiveTraceServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type CreateRuleRequest 

type CreateRuleRequest struct {
	Rule                 *Rule    `protobuf:"bytes,2,opt,name=rule,proto3" json:"rule,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRuleRequest) Descriptor 

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

func (*CreateRuleRequest) GetRule 

func (m *CreateRuleRequest) GetRule() *Rule

func (*CreateRuleRequest) ProtoMessage 

func (*CreateRuleRequest) ProtoMessage()

func (*CreateRuleRequest) Reset 

func (m *CreateRuleRequest) Reset()

func (*CreateRuleRequest) String 

func (m *CreateRuleRequest) String() string

func (*CreateRuleRequest) XXX_DiscardUnknown 

func (m *CreateRuleRequest) XXX_DiscardUnknown()

func (*CreateRuleRequest) XXX_Marshal 

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

func (*CreateRuleRequest) XXX_Merge 

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

func (*CreateRuleRequest) XXX_Size 

func (m *CreateRuleRequest) XXX_Size() int

func (*CreateRuleRequest) XXX_Unmarshal 

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

type CreateRuleResponse 

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

func (*CreateRuleResponse) Descriptor 

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

func (*CreateRuleResponse) ProtoMessage 

func (*CreateRuleResponse) ProtoMessage()

func (*CreateRuleResponse) Reset 

func (m *CreateRuleResponse) Reset()

func (*CreateRuleResponse) String 

func (m *CreateRuleResponse) String() string

func (*CreateRuleResponse) XXX_DiscardUnknown 

func (m *CreateRuleResponse) XXX_DiscardUnknown()

func (*CreateRuleResponse) XXX_Marshal 

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

func (*CreateRuleResponse) XXX_Merge 

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

func (*CreateRuleResponse) XXX_Size 

func (m *CreateRuleResponse) XXX_Size() int

func (*CreateRuleResponse) XXX_Unmarshal 

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

type Event 

type Event struct {
	PID                  uint32            `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"`
	TGID                 uint32            `protobuf:"varint,2,opt,name=TGID,proto3" json:"TGID,omitempty"`
	UID                  uint32            `protobuf:"varint,3,opt,name=UID,proto3" json:"UID,omitempty"`
	GID                  uint32            `protobuf:"varint,4,opt,name=GID,proto3" json:"GID,omitempty"`
	ReturnValue          int32             `protobuf:"varint,9,opt,name=returnValue,proto3" json:"returnValue,omitempty"`
	Command              string            `protobuf:"bytes,10,opt,name=command,proto3" json:"command,omitempty"`
	Data                 map[string]string `` /* 149-byte string literal not displayed */
	ContainerID          string            `protobuf:"bytes,6,opt,name=containerID,proto3" json:"containerID,omitempty"`
	ContainerRuntime     string            `protobuf:"bytes,7,opt,name=containerRuntime,proto3" json:"containerRuntime,omitempty"`
	Tracer               string            `protobuf:"bytes,8,opt,name=tracer,proto3" json:"tracer,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Event) Descriptor 

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

func (*Event) GetCommand 

func (m *Event) GetCommand() string

func (*Event) GetContainerID 

func (m *Event) GetContainerID() string

func (*Event) GetContainerRuntime 

func (m *Event) GetContainerRuntime() string

func (*Event) GetData 

func (m *Event) GetData() map[string]string

func (*Event) GetGID 

func (m *Event) GetGID() uint32

func (*Event) GetPID 

func (m *Event) GetPID() uint32

func (*Event) GetReturnValue 

func (m *Event) GetReturnValue() int32

func (*Event) GetTGID 

func (m *Event) GetTGID() uint32

func (*Event) GetTracer 

func (m *Event) GetTracer() string

func (*Event) GetUID 

func (m *Event) GetUID() uint32

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type Filter 

type Filter struct {
	Values               []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Filter) Descriptor 

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

func (*Filter) GetValues 

func (m *Filter) GetValues() []string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) String 

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal 

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

func (*Filter) XXX_Merge 

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

func (*Filter) XXX_Size 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal 

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

type ListRulesRequest 

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

func (*ListRulesRequest) Descriptor 

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

func (*ListRulesRequest) ProtoMessage 

func (*ListRulesRequest) ProtoMessage()

func (*ListRulesRequest) Reset 

func (m *ListRulesRequest) Reset()

func (*ListRulesRequest) String 

func (m *ListRulesRequest) String() string

func (*ListRulesRequest) XXX_DiscardUnknown 

func (m *ListRulesRequest) XXX_DiscardUnknown()

func (*ListRulesRequest) XXX_Marshal 

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

func (*ListRulesRequest) XXX_Merge 

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

func (*ListRulesRequest) XXX_Size 

func (m *ListRulesRequest) XXX_Size() int

func (*ListRulesRequest) XXX_Unmarshal 

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

type ListRulesResponse 

type ListRulesResponse struct {
	Rules                []*Rule  `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListRulesResponse) Descriptor 

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

func (*ListRulesResponse) GetRules 

func (m *ListRulesResponse) GetRules() []*Rule

func (*ListRulesResponse) ProtoMessage 

func (*ListRulesResponse) ProtoMessage()

func (*ListRulesResponse) Reset 

func (m *ListRulesResponse) Reset()

func (*ListRulesResponse) String 

func (m *ListRulesResponse) String() string

func (*ListRulesResponse) XXX_DiscardUnknown 

func (m *ListRulesResponse) XXX_DiscardUnknown()

func (*ListRulesResponse) XXX_Marshal 

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

func (*ListRulesResponse) XXX_Merge 

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

func (*ListRulesResponse) XXX_Size 

func (m *ListRulesResponse) XXX_Size() int

func (*ListRulesResponse) XXX_Unmarshal 

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

type LiveTraceRequest 

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

func (*LiveTraceRequest) Descriptor 

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

func (*LiveTraceRequest) ProtoMessage 

func (*LiveTraceRequest) ProtoMessage()

func (*LiveTraceRequest) Reset 

func (m *LiveTraceRequest) Reset()

func (*LiveTraceRequest) String 

func (m *LiveTraceRequest) String() string

func (*LiveTraceRequest) XXX_DiscardUnknown 

func (m *LiveTraceRequest) XXX_DiscardUnknown()

func (*LiveTraceRequest) XXX_Marshal 

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

func (*LiveTraceRequest) XXX_Merge 

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

func (*LiveTraceRequest) XXX_Size 

func (m *LiveTraceRequest) XXX_Size() int

func (*LiveTraceRequest) XXX_Unmarshal 

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

type RemoveRuleRequest 

type RemoveRuleRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tracer               string   `protobuf:"bytes,2,opt,name=tracer,proto3" json:"tracer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveRuleRequest) Descriptor 

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

func (*RemoveRuleRequest) GetName 

func (m *RemoveRuleRequest) GetName() string

func (*RemoveRuleRequest) GetTracer 

func (m *RemoveRuleRequest) GetTracer() string

func (*RemoveRuleRequest) ProtoMessage 

func (*RemoveRuleRequest) ProtoMessage()

func (*RemoveRuleRequest) Reset 

func (m *RemoveRuleRequest) Reset()

func (*RemoveRuleRequest) String 

func (m *RemoveRuleRequest) String() string

func (*RemoveRuleRequest) XXX_DiscardUnknown 

func (m *RemoveRuleRequest) XXX_DiscardUnknown()

func (*RemoveRuleRequest) XXX_Marshal 

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

func (*RemoveRuleRequest) XXX_Merge 

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

func (*RemoveRuleRequest) XXX_Size 

func (m *RemoveRuleRequest) XXX_Size() int

func (*RemoveRuleRequest) XXX_Unmarshal 

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

type RemoveRuleResponse 

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

func (*RemoveRuleResponse) Descriptor 

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

func (*RemoveRuleResponse) ProtoMessage 

func (*RemoveRuleResponse) ProtoMessage()

func (*RemoveRuleResponse) Reset 

func (m *RemoveRuleResponse) Reset()

func (*RemoveRuleResponse) String 

func (m *RemoveRuleResponse) String() string

func (*RemoveRuleResponse) XXX_DiscardUnknown 

func (m *RemoveRuleResponse) XXX_DiscardUnknown()

func (*RemoveRuleResponse) XXX_Marshal 

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

func (*RemoveRuleResponse) XXX_Merge 

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

func (*RemoveRuleResponse) XXX_Size 

func (m *RemoveRuleResponse) XXX_Size() int

func (*RemoveRuleResponse) XXX_Unmarshal 

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

type Rule 

type Rule struct {
	Name                 string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tracer               string             `protobuf:"bytes,2,opt,name=tracer,proto3" json:"tracer,omitempty"`
	FilterEvents         map[string]*Filter `` /* 165-byte string literal not displayed */
	ContainerRuntimes    []string           `protobuf:"bytes,4,rep,name=containerRuntimes,proto3" json:"containerRuntimes,omitempty"`
	Actions              []string           `protobuf:"bytes,5,rep,name=actions,proto3" json:"actions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Rule) Descriptor 

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

func (*Rule) GetActions 

func (m *Rule) GetActions() []string

func (*Rule) GetContainerRuntimes 

func (m *Rule) GetContainerRuntimes() []string

func (*Rule) GetFilterEvents 

func (m *Rule) GetFilterEvents() map[string]*Filter

func (*Rule) GetName 

func (m *Rule) GetName() string

func (*Rule) GetTracer 

func (m *Rule) GetTracer() string

func (*Rule) ProtoMessage 

func (*Rule) ProtoMessage()

func (*Rule) Reset 

func (m *Rule) Reset()

func (*Rule) String 

func (m *Rule) String() string

func (*Rule) XXX_DiscardUnknown 

func (m *Rule) XXX_DiscardUnknown()

func (*Rule) XXX_Marshal 

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

func (*Rule) XXX_Merge 

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

func (*Rule) XXX_Size 

func (m *Rule) XXX_Size() int

func (*Rule) XXX_Unmarshal 

func (m *Rule) 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.
JackTT - Gopher 🇻🇳