topic

Documentation

Overview

Package topic is a generated protocol buffer package.

It is generated from these files:

github.com/appcelerator/amp/api/rpc/topic/topic.proto

It has these top-level messages:

TopicEntry
CreateRequest
CreateReply
ListRequest
ListReply
DeleteRequest
DeleteReply

Index

• func RegisterTopicServer(s *grpc.Server, srv TopicServer)
• type CreateReply
  • func (*CreateReply) Descriptor() ([]byte, []int)
  • func (m *CreateReply) GetTopic() *TopicEntry
  • func (*CreateReply) ProtoMessage()
  • func (m *CreateReply) Reset()
  • func (m *CreateReply) String() string
• type CreateRequest
  • func (*CreateRequest) Descriptor() ([]byte, []int)
  • func (m *CreateRequest) GetTopic() *TopicEntry
  • func (*CreateRequest) ProtoMessage()
  • func (m *CreateRequest) Reset()
  • func (m *CreateRequest) String() string
• type DeleteReply
  • func (*DeleteReply) Descriptor() ([]byte, []int)
  • func (m *DeleteReply) GetTopic() *TopicEntry
  • func (*DeleteReply) ProtoMessage()
  • func (m *DeleteReply) Reset()
  • func (m *DeleteReply) String() string
• type DeleteRequest
  • func (*DeleteRequest) Descriptor() ([]byte, []int)
  • func (*DeleteRequest) ProtoMessage()
  • func (m *DeleteRequest) Reset()
  • func (m *DeleteRequest) String() string
• type ListReply
  • func (*ListReply) Descriptor() ([]byte, []int)
  • func (m *ListReply) GetTopics() []*TopicEntry
  • func (*ListReply) ProtoMessage()
  • func (m *ListReply) Reset()
  • func (m *ListReply) String() string
• type ListRequest
  • func (*ListRequest) Descriptor() ([]byte, []int)
  • func (*ListRequest) ProtoMessage()
  • func (m *ListRequest) Reset()
  • func (m *ListRequest) String() string
• type Server
  • func (s *Server) Create(ctx context.Context, in *CreateRequest) (*CreateReply, error)
  • func (s *Server) Delete(ctx context.Context, in *DeleteRequest) (*DeleteReply, error)
  • func (s *Server) List(ctx context.Context, in *ListRequest) (*ListReply, error)
• type TopicClient
  • func NewTopicClient(cc *grpc.ClientConn) TopicClient
• type TopicEntry
  • func (*TopicEntry) Descriptor() ([]byte, []int)
  • func (*TopicEntry) ProtoMessage()
  • func (m *TopicEntry) Reset()
  • func (m *TopicEntry) String() string
• type TopicServer

Functions

func RegisterTopicServer

func RegisterTopicServer(s *grpc.Server, srv TopicServer)

Types

type CreateReply

type CreateReply struct {
	Topic *TopicEntry `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
}

func (*CreateReply) Descriptor

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

func (*CreateReply) GetTopic

func (m *CreateReply) GetTopic() *TopicEntry

func (*CreateReply) ProtoMessage

func (*CreateReply) ProtoMessage()

func (*CreateReply) Reset

func (m *CreateReply) Reset()

func (*CreateReply) String

func (m *CreateReply) String() string

type CreateRequest

type CreateRequest struct {
	Topic *TopicEntry `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
}

func (*CreateRequest) Descriptor

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

func (*CreateRequest) GetTopic

func (m *CreateRequest) GetTopic() *TopicEntry

func (*CreateRequest) ProtoMessage

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset

func (m *CreateRequest) Reset()

func (*CreateRequest) String

func (m *CreateRequest) String() string

type DeleteReply

type DeleteReply struct {
	Topic *TopicEntry `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
}

func (*DeleteReply) Descriptor

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

func (*DeleteReply) GetTopic

func (m *DeleteReply) GetTopic() *TopicEntry

func (*DeleteReply) ProtoMessage

func (*DeleteReply) ProtoMessage()

func (*DeleteReply) Reset

func (m *DeleteReply) Reset()

func (*DeleteReply) String

func (m *DeleteReply) String() string

type DeleteRequest

type DeleteRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

func (*DeleteRequest) Descriptor

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

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String

func (m *DeleteRequest) String() string

type ListReply

type ListReply struct {
	Topics []*TopicEntry `protobuf:"bytes,1,rep,name=topics" json:"topics,omitempty"`
}

func (*ListReply) Descriptor

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

func (*ListReply) GetTopics

func (m *ListReply) GetTopics() []*TopicEntry

func (*ListReply) ProtoMessage

func (*ListReply) ProtoMessage()

func (*ListReply) Reset

func (m *ListReply) Reset()

func (*ListReply) String

func (m *ListReply) String() string

type ListRequest

type ListRequest struct {
}

func (*ListRequest) Descriptor

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

func (*ListRequest) ProtoMessage

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset

func (m *ListRequest) Reset()

func (*ListRequest) String

func (m *ListRequest) String() string

type Server

type Server struct {
	Store storage.Interface
	Nats  stan.Conn
}

Server is used to implement topic.TopicServer

func (*Server) Create

func (s *Server) Create(ctx context.Context, in *CreateRequest) (*CreateReply, error)

Create implements topic.TopicServer

func (*Server) Delete

func (s *Server) Delete(ctx context.Context, in *DeleteRequest) (*DeleteReply, error)

Delete implements topic.TopicServer

func (*Server) List

func (s *Server) List(ctx context.Context, in *ListRequest) (*ListReply, error)

List implements topic.TopicServer

type TopicClient

type TopicClient interface {
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateReply, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListReply, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteReply, error)
}

func NewTopicClient

func NewTopicClient(cc *grpc.ClientConn) TopicClient

type TopicEntry

type TopicEntry struct {
	Id   string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
}

func (*TopicEntry) Descriptor

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

func (*TopicEntry) ProtoMessage

func (*TopicEntry) ProtoMessage()

func (*TopicEntry) Reset

func (m *TopicEntry) Reset()

func (*TopicEntry) String

func (m *TopicEntry) String() string

type TopicServer

type TopicServer interface {
	Create(context.Context, *CreateRequest) (*CreateReply, error)
	List(context.Context, *ListRequest) (*ListReply, error)
	Delete(context.Context, *DeleteRequest) (*DeleteReply, error)
}