emitto_service

package
v0.0.0-...-6e31670 Latest Latest
Warning

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

Go to latest
Published: Jul 22, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterEmittoServer

func RegisterEmittoServer(s *grpc.Server, srv EmittoServer)

Types

type AddLocationRequest

type AddLocationRequest struct {
	Location             *Location `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*AddLocationRequest) Descriptor

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

func (*AddLocationRequest) GetLocation

func (m *AddLocationRequest) GetLocation() *Location

func (*AddLocationRequest) ProtoMessage

func (*AddLocationRequest) ProtoMessage()

func (*AddLocationRequest) Reset

func (m *AddLocationRequest) Reset()

func (*AddLocationRequest) String

func (m *AddLocationRequest) String() string

func (*AddLocationRequest) XXX_DiscardUnknown

func (m *AddLocationRequest) XXX_DiscardUnknown()

func (*AddLocationRequest) XXX_Marshal

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

func (*AddLocationRequest) XXX_Merge

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

func (*AddLocationRequest) XXX_Size

func (m *AddLocationRequest) XXX_Size() int

func (*AddLocationRequest) XXX_Unmarshal

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

type AddRuleRequest

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

func (*AddRuleRequest) Descriptor

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

func (*AddRuleRequest) GetRule

func (m *AddRuleRequest) GetRule() *Rule

func (*AddRuleRequest) ProtoMessage

func (*AddRuleRequest) ProtoMessage()

func (*AddRuleRequest) Reset

func (m *AddRuleRequest) Reset()

func (*AddRuleRequest) String

func (m *AddRuleRequest) String() string

func (*AddRuleRequest) XXX_DiscardUnknown

func (m *AddRuleRequest) XXX_DiscardUnknown()

func (*AddRuleRequest) XXX_Marshal

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

func (*AddRuleRequest) XXX_Merge

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

func (*AddRuleRequest) XXX_Size

func (m *AddRuleRequest) XXX_Size() int

func (*AddRuleRequest) XXX_Unmarshal

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

type DeleteLocationRequest

type DeleteLocationRequest struct {
	LocationName         string   `protobuf:"bytes,1,opt,name=location_name,json=locationName,proto3" json:"location_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteLocationRequest) Descriptor

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

func (*DeleteLocationRequest) GetLocationName

func (m *DeleteLocationRequest) GetLocationName() string

func (*DeleteLocationRequest) ProtoMessage

func (*DeleteLocationRequest) ProtoMessage()

func (*DeleteLocationRequest) Reset

func (m *DeleteLocationRequest) Reset()

func (*DeleteLocationRequest) String

func (m *DeleteLocationRequest) String() string

func (*DeleteLocationRequest) XXX_DiscardUnknown

func (m *DeleteLocationRequest) XXX_DiscardUnknown()

func (*DeleteLocationRequest) XXX_Marshal

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

func (*DeleteLocationRequest) XXX_Merge

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

func (*DeleteLocationRequest) XXX_Size

func (m *DeleteLocationRequest) XXX_Size() int

func (*DeleteLocationRequest) XXX_Unmarshal

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

type DeleteRuleRequest

type DeleteRuleRequest struct {
	RuleId               int64    `protobuf:"varint,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRuleRequest) Descriptor

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

func (*DeleteRuleRequest) GetRuleId

func (m *DeleteRuleRequest) GetRuleId() int64

func (*DeleteRuleRequest) ProtoMessage

func (*DeleteRuleRequest) ProtoMessage()

func (*DeleteRuleRequest) Reset

func (m *DeleteRuleRequest) Reset()

func (*DeleteRuleRequest) String

func (m *DeleteRuleRequest) String() string

func (*DeleteRuleRequest) XXX_DiscardUnknown

func (m *DeleteRuleRequest) XXX_DiscardUnknown()

func (*DeleteRuleRequest) XXX_Marshal

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

func (*DeleteRuleRequest) XXX_Merge

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

func (*DeleteRuleRequest) XXX_Size

func (m *DeleteRuleRequest) XXX_Size() int

func (*DeleteRuleRequest) XXX_Unmarshal

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

type DeployRulesRequest

type DeployRulesRequest struct {
	Location             *Location `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeployRulesRequest) Descriptor

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

func (*DeployRulesRequest) GetLocation

func (m *DeployRulesRequest) GetLocation() *Location

func (*DeployRulesRequest) ProtoMessage

func (*DeployRulesRequest) ProtoMessage()

func (*DeployRulesRequest) Reset

func (m *DeployRulesRequest) Reset()

func (*DeployRulesRequest) String

func (m *DeployRulesRequest) String() string

func (*DeployRulesRequest) XXX_DiscardUnknown

func (m *DeployRulesRequest) XXX_DiscardUnknown()

func (*DeployRulesRequest) XXX_Marshal

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

func (*DeployRulesRequest) XXX_Merge

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

func (*DeployRulesRequest) XXX_Size

func (m *DeployRulesRequest) XXX_Size() int

func (*DeployRulesRequest) XXX_Unmarshal

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

type DeployRulesResponse

type DeployRulesResponse struct {
	ClientId             string         `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Status               *status.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DeployRulesResponse) Descriptor

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

func (*DeployRulesResponse) GetClientId

func (m *DeployRulesResponse) GetClientId() string

func (*DeployRulesResponse) GetStatus

func (m *DeployRulesResponse) GetStatus() *status.Status

func (*DeployRulesResponse) ProtoMessage

func (*DeployRulesResponse) ProtoMessage()

func (*DeployRulesResponse) Reset

func (m *DeployRulesResponse) Reset()

func (*DeployRulesResponse) String

func (m *DeployRulesResponse) String() string

func (*DeployRulesResponse) XXX_DiscardUnknown

func (m *DeployRulesResponse) XXX_DiscardUnknown()

func (*DeployRulesResponse) XXX_Marshal

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

func (*DeployRulesResponse) XXX_Merge

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

func (*DeployRulesResponse) XXX_Size

func (m *DeployRulesResponse) XXX_Size() int

func (*DeployRulesResponse) XXX_Unmarshal

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

type EmittoClient

type EmittoClient interface {
	DeployRules(ctx context.Context, in *DeployRulesRequest, opts ...grpc.CallOption) (Emitto_DeployRulesClient, error)
	AddRule(ctx context.Context, in *AddRuleRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ModifyRule(ctx context.Context, in *ModifyRuleRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteRule(ctx context.Context, in *DeleteRuleRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ListRules(ctx context.Context, in *ListRulesRequest, opts ...grpc.CallOption) (*ListRulesResponse, error)
	AddLocation(ctx context.Context, in *AddLocationRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ModifyLocation(ctx context.Context, in *ModifyLocationRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteLocation(ctx context.Context, in *DeleteLocationRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ListLocations(ctx context.Context, in *ListLocationsRequest, opts ...grpc.CallOption) (*ListLocationsResponse, error)
}

EmittoClient is the client API for Emitto service.

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

func NewEmittoClient

func NewEmittoClient(cc *grpc.ClientConn) EmittoClient

type EmittoServer

EmittoServer is the server API for Emitto service.

type Emitto_DeployRulesClient

type Emitto_DeployRulesClient interface {
	Recv() (*DeployRulesResponse, error)
	grpc.ClientStream
}

type Emitto_DeployRulesServer

type Emitto_DeployRulesServer interface {
	Send(*DeployRulesResponse) error
	grpc.ServerStream
}

type ListLocationsRequest

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

func (*ListLocationsRequest) Descriptor

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

func (*ListLocationsRequest) ProtoMessage

func (*ListLocationsRequest) ProtoMessage()

func (*ListLocationsRequest) Reset

func (m *ListLocationsRequest) Reset()

func (*ListLocationsRequest) String

func (m *ListLocationsRequest) String() string

func (*ListLocationsRequest) XXX_DiscardUnknown

func (m *ListLocationsRequest) XXX_DiscardUnknown()

func (*ListLocationsRequest) XXX_Marshal

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

func (*ListLocationsRequest) XXX_Merge

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

func (*ListLocationsRequest) XXX_Size

func (m *ListLocationsRequest) XXX_Size() int

func (*ListLocationsRequest) XXX_Unmarshal

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

type ListLocationsResponse

type ListLocationsResponse struct {
	Locations            []*Location `protobuf:"bytes,1,rep,name=locations,proto3" json:"locations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ListLocationsResponse) Descriptor

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

func (*ListLocationsResponse) GetLocations

func (m *ListLocationsResponse) GetLocations() []*Location

func (*ListLocationsResponse) ProtoMessage

func (*ListLocationsResponse) ProtoMessage()

func (*ListLocationsResponse) Reset

func (m *ListLocationsResponse) Reset()

func (*ListLocationsResponse) String

func (m *ListLocationsResponse) String() string

func (*ListLocationsResponse) XXX_DiscardUnknown

func (m *ListLocationsResponse) XXX_DiscardUnknown()

func (*ListLocationsResponse) XXX_Marshal

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

func (*ListLocationsResponse) XXX_Merge

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

func (*ListLocationsResponse) XXX_Size

func (m *ListLocationsResponse) XXX_Size() int

func (*ListLocationsResponse) XXX_Unmarshal

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

type ListRulesRequest

type ListRulesRequest struct {
	RuleIds              []int64  `protobuf:"varint,1,rep,packed,name=rule_ids,json=ruleIds,proto3" json:"rule_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListRulesRequest) Descriptor

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

func (*ListRulesRequest) GetRuleIds

func (m *ListRulesRequest) GetRuleIds() []int64

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 Location

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

func (*Location) Descriptor

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

func (*Location) GetName

func (m *Location) GetName() string

func (*Location) GetZones

func (m *Location) GetZones() []string

func (*Location) ProtoMessage

func (*Location) ProtoMessage()

func (*Location) Reset

func (m *Location) Reset()

func (*Location) String

func (m *Location) String() string

func (*Location) XXX_DiscardUnknown

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal

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

func (*Location) XXX_Merge

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

func (*Location) XXX_Size

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal

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

type ModifyLocationRequest

type ModifyLocationRequest struct {
	Location             *Location             `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	FieldMask            *field_mask.FieldMask `protobuf:"bytes,2,opt,name=field_mask,json=fieldMask,proto3" json:"field_mask,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ModifyLocationRequest) Descriptor

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

func (*ModifyLocationRequest) GetFieldMask

func (m *ModifyLocationRequest) GetFieldMask() *field_mask.FieldMask

func (*ModifyLocationRequest) GetLocation

func (m *ModifyLocationRequest) GetLocation() *Location

func (*ModifyLocationRequest) ProtoMessage

func (*ModifyLocationRequest) ProtoMessage()

func (*ModifyLocationRequest) Reset

func (m *ModifyLocationRequest) Reset()

func (*ModifyLocationRequest) String

func (m *ModifyLocationRequest) String() string

func (*ModifyLocationRequest) XXX_DiscardUnknown

func (m *ModifyLocationRequest) XXX_DiscardUnknown()

func (*ModifyLocationRequest) XXX_Marshal

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

func (*ModifyLocationRequest) XXX_Merge

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

func (*ModifyLocationRequest) XXX_Size

func (m *ModifyLocationRequest) XXX_Size() int

func (*ModifyLocationRequest) XXX_Unmarshal

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

type ModifyRuleRequest

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

func (*ModifyRuleRequest) Descriptor

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

func (*ModifyRuleRequest) GetFieldMask

func (m *ModifyRuleRequest) GetFieldMask() *field_mask.FieldMask

func (*ModifyRuleRequest) GetRule

func (m *ModifyRuleRequest) GetRule() *Rule

func (*ModifyRuleRequest) ProtoMessage

func (*ModifyRuleRequest) ProtoMessage()

func (*ModifyRuleRequest) Reset

func (m *ModifyRuleRequest) Reset()

func (*ModifyRuleRequest) String

func (m *ModifyRuleRequest) String() string

func (*ModifyRuleRequest) XXX_DiscardUnknown

func (m *ModifyRuleRequest) XXX_DiscardUnknown()

func (*ModifyRuleRequest) XXX_Marshal

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

func (*ModifyRuleRequest) XXX_Merge

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

func (*ModifyRuleRequest) XXX_Size

func (m *ModifyRuleRequest) XXX_Size() int

func (*ModifyRuleRequest) XXX_Unmarshal

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

type Rule

type Rule struct {
	Id                   int64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Body                 string   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	LocationZones        []string `protobuf:"bytes,3,rep,name=location_zones,json=locationZones,proto3" json:"location_zones,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Rule) Descriptor

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

func (*Rule) GetBody

func (m *Rule) GetBody() string

func (*Rule) GetId

func (m *Rule) GetId() int64

func (*Rule) GetLocationZones

func (m *Rule) GetLocationZones() []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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL